mirror of
https://github.com/brianc/node-postgres.git
synced 2026-01-18 15:55:05 +00:00
0895460046
* Fix one unintentional possible breaking change & update readme * Update changelog more * Update CHANGELOG.md Co-Authored-By: Charmander <~@charmander.me> Co-authored-by: Charmander <~@charmander.me>
27 lines
762 B
JavaScript
27 lines
762 B
JavaScript
var assert = require('assert')
|
|
var QueryStream = require('../')
|
|
|
|
describe('stream config options', () => {
|
|
// this is mostly for backwards compatability.
|
|
it('sets readable.highWaterMark based on batch size', () => {
|
|
var stream = new QueryStream('SELECT NOW()', [], {
|
|
batchSize: 88
|
|
})
|
|
assert.equal(stream._readableState.highWaterMark, 88)
|
|
})
|
|
|
|
it('sets readable.highWaterMark based on highWaterMark config', () => {
|
|
var stream = new QueryStream('SELECT NOW()', [], {
|
|
highWaterMark: 88
|
|
})
|
|
|
|
assert.equal(stream._readableState.highWaterMark, 88)
|
|
})
|
|
|
|
it('defaults to 100 for highWaterMark', () => {
|
|
var stream = new QueryStream('SELECT NOW()', [])
|
|
|
|
assert.equal(stream._readableState.highWaterMark, 100)
|
|
})
|
|
})
|