Lines Matching refs:newStream

428     const newStream = compose(  constant
450     assert.strictEqual(newStream.writableObjectMode, false);
451     assert.strictEqual(newStream.readableObjectMode, true);
453     newStream.write('Steve Rogers');
454     newStream.write('On your left');
456     newStream.end();
458 …assert.deepStrictEqual(await newStream.toArray(), [{ value: 'Steve Rogers' }, { value: 'On your le…
466     const newStream = compose(  constant
486     assert.strictEqual(newStream.writableObjectMode, true);
487     assert.strictEqual(newStream.readableObjectMode, false);
489     newStream.write({ value: 'Steve Rogers' });
490     newStream.write({ value: 'On your left' });
492     newStream.end();
494     assert.deepStrictEqual(await newStream.toArray(), [Buffer.from('Steve RogersOn your left')]);