Lines Matching refs:stream
13 } = require('stream');
14 const pipelinep = require('stream/promises').pipeline;
133 [read, transform, write].forEach((stream) => {
134 stream.on('error', common.mustCall((err) => {
382 assert(finished, 'last stream finished');
573 const stream = new PassThrough();
575 stream.on('error', common.mustCall());
579 stream,
586 stream.destroy(new Error('oh no'));
826 // once from stream wrapper and
1057 pipeline(rs, async function*(stream) { // eslint-disable-line require-yield
1058 for await (const chunk of stream) { // eslint-disable-line no-unused-vars
1531 // Mimics a legacy stream without the .destroy method