mirror of
https://github.com/brianc/node-postgres.git
synced 2026-01-18 15:55:05 +00:00
db1b95e5f3
git-subtree-dir: packages/pg-query-stream git-subtree-mainline: cccf84e14b3281b753e1baab7bc194aaac5024a8 git-subtree-split: 9ced05e8aab65f3fdf1a67add87bfc9035e487e8
19 lines
597 B
JavaScript
19 lines
597 B
JavaScript
var concat = require('concat-stream')
|
|
var tester = require('stream-tester')
|
|
var JSONStream = require('JSONStream')
|
|
|
|
var QueryStream = require('../')
|
|
|
|
require('./helper')('pauses', function (client) {
|
|
it('pauses', function (done) {
|
|
this.timeout(5000)
|
|
var stream = new QueryStream('SELECT * FROM generate_series(0, $1) num', [200], {batchSize: 2, highWaterMark: 2})
|
|
var query = client.query(stream)
|
|
var pauser = tester.createPauseStream(0.1, 100)
|
|
query.pipe(JSONStream.stringify()).pipe(pauser).pipe(concat(function (json) {
|
|
JSON.parse(json)
|
|
done()
|
|
}))
|
|
})
|
|
})
|