We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 5687baf commit fe741efCopy full SHA for fe741ef
test/parallel/test-stream-pipeline.js
@@ -1211,3 +1211,23 @@ const net = require('net');
1211
d.write('test');
1212
d.end();
1213
}
1214
+
1215
+{
1216
+ const r = new Readable({
1217
+ read() {}
1218
+ });
1219
+ r.push('hello');
1220
+ r.push('world');
1221
+ r.push(null);
1222
+ let res = '';
1223
+ const w = new Writable({
1224
+ write(chunk, encoding, callback) {
1225
+ res += chunk;
1226
+ callback();
1227
+ }
1228
1229
+ pipeline([r, w], common.mustCall((err) => {
1230
+ assert.ok(!err);
1231
+ assert.strictEqual(res, 'helloworld');
1232
+ }));
1233
+}
0 commit comments