Skip to content
Closed
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 3 additions & 3 deletions test/parallel/test-stream-pipe-flow.js
Original file line number Diff line number Diff line change
Expand Up @@ -41,17 +41,17 @@ const { Readable, Writable, PassThrough } = require('stream');
.pipe(new PassThrough({ objectMode: true, highWaterMark: 2 }))
.pipe(new PassThrough({ objectMode: true, highWaterMark: 2 }));

pt.on('end', function() {
pt.on('end', () => {
wrapper.push(null);
});

const wrapper = new Readable({
objectMode: true,
read: () => {
process.nextTick(function() {
process.nextTick( () => {
Comment thread
pushkalb123 marked this conversation as resolved.
Outdated
let data = pt.read();
if (data === null) {
pt.once('readable', function() {
pt.once('readable', () => {
data = pt.read();
if (data !== null) wrapper.push(data);
});
Expand Down