Lines Matching refs:stream
13 const eos = require('internal/streams/end-of-stream');
50 function destroyer(stream, reading, writing) {
52 stream.on('close', () => {
56 const cleanup = eos(stream, { readable: reading, writable: writing }, (err) => {
64 destroyImpl.destroyer(stream, err || new ERR_STREAM_DESTROYED('pipe'));
72 // a single stream. Therefore optimize for the average case instead of
74 validateFunction(streams[streams.length - 1], 'streams[stream.length - 1]');
201 // Need to cleanup event listeners if last stream is readable
253 const stream = streams[i];
259 if (isNodeStream(stream)) {
261 const { destroy, cleanup } = destroyer(stream, reading, writing);
264 if (isReadable(stream) && isLastStream) {
269 // Catch stream errors that occur after pipe/pump has completed.
279 stream.on('error', onError);
280 if (isReadable(stream) && isLastStream) {
282 stream.removeListener('error', onError);
288 if (typeof stream === 'function') {
289 ret = stream({ signal });
294 } else if (isIterable(stream) || isReadableNodeStream(stream) || isTransformStream(stream)) {
295 ret = stream;
297 ret = Duplex.from(stream);
299 } else if (typeof stream === 'function') {
305 ret = stream(ret, { signal });
317 // If the last argument to pipeline is not a stream
318 // we must create a proxy stream so that pipeline(...)
319 // always returns a stream which can be further
320 // composed through `.pipe(stream)`.
366 } else if (isNodeStream(stream)) {
369 const cleanup = pipe(ret, stream, finish, { end });
370 if (isReadable(stream) && isLastStream) {
376 pumpToNode(toRead, stream, finish, { end });
379 pumpToNode(ret, stream, finish, { end });
384 ret = stream;
385 } else if (isWebStream(stream)) {
388 pumpToWeb(makeAsyncIterable(ret), stream, finish, { end });
391 pumpToWeb(ret, stream, finish, { end });
394 pumpToWeb(ret.readable, stream, finish, { end });
399 ret = stream;
401 ret = Duplex.from(stream);
451 // stream has been ended and no error emitted. This should be allowed in
452 // favor of backwards compatibility. Since the stream is piped to a