We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent cb7422f commit 4fc4871Copy full SHA for 4fc4871
test/run_pass/test_stream_duplex.js
@@ -13,8 +13,26 @@
13
* limitations under the License.
14
*/
15
16
- var assert = require('assert');
+var assert = require('assert');
17
+var Duplex = require('stream').Duplex;
18
- var Duplex = require('stream').Duplex;
19
+var duplex = Duplex({ highWaterMark: 0 });
20
- var duplex = Duplex({highWaterMark: 0});
21
+assert(duplex instanceof Duplex);
22
+assert(duplex.write);
23
+assert(duplex.read);
24
+
25
+var msg1 = 'message 1';
26
+var msg2 = 'message 2';
27
28
+duplex._write = function(chunk, callback) {
29
+ assert.equal(chunk == msg1, true);
30
+ duplex.push(msg2);
31
+ duplex.end();
32
+}
33
+duplex._readyToWrite();
34
+duplex.write(msg1);
35
36
+process.on('exit', function() {
37
+ assert.equal(duplex.read() == msg2, true);
38
+});
0 commit comments