Lines Matching refs:stream
20 const { finished } = require('internal/streams/end-of-stream');
44 function compose(stream, options) {
52 if (isNodeStream(stream) && !isWritable(stream)) {
53 throw new ERR_INVALID_ARG_VALUE('stream', stream, 'must be writable');
56 const composedStream = staticCompose(this, stream);
98 const stream = this;
131 for await (let val of stream) {
291 // missing if the stream has no items in it - but the code is still appropriate
295 this.message = 'Reduce of an empty stream requires an initial value';