Lines Matching refs:readable
56 const cleanup = eos(stream, { readable: reading, writable: writing }, (err) => {
91 Readable = require('internal/streams/readable');
128 const cleanup = eos(writable, { readable: false }, resume);
155 async function pumpToWeb(readable, writable, finish, { end }) {
162 for await (const chunk of readable) {
201 // Need to cleanup event listeners if last stream is readable
301 ret = makeAsyncIterable(ret?.readable);
350 const toRead = ret.readable || ret;
374 const toRead = ret.readable || ret;
394 pumpToWeb(ret.readable, stream, finish, { end });
442 eos(src, { readable: true, writable: false }, (err) => {
449 // Some readable streams will emit 'close' before 'end'. However, since
450 // this is on the readable side 'end' should still be emitted if the
464 return eos(dst, { readable: false, writable: true }, finish);