Skip to content

Commit 40ef239

Browse files
italoacasasMyles Borins
authored and
Myles Borins
committed
test: writable stream needDrain state
Add a test for _writableState.needDrain. PR-URL: #8799 Reviewed-By: Colin Ihrig <[email protected]> Reviewed-By: Matteo Collina <[email protected]> Reviewed-By: Anna Henningsen <[email protected]> Reviewed-By: James M Snell <[email protected]> Related: #8686
1 parent ba4a3ed commit 40ef239

File tree

1 file changed

+23
-0
lines changed

1 file changed

+23
-0
lines changed
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
'use strict';
2+
3+
const common = require('../common');
4+
const stream = require('stream');
5+
const assert = require('assert');
6+
7+
const transform = new stream.Transform({
8+
transform: _transform,
9+
highWaterMark: 1
10+
});
11+
12+
function _transform(chunk, encoding, cb) {
13+
assert.strictEqual(transform._writableState.needDrain, true);
14+
cb();
15+
}
16+
17+
assert.strictEqual(transform._writableState.needDrain, false);
18+
19+
transform.write('asdasd', common.mustCall(() => {
20+
assert.strictEqual(transform._writableState.needDrain, false);
21+
}));
22+
23+
assert.strictEqual(transform._writableState.needDrain, true);

0 commit comments

Comments
 (0)