Lines Matching refs:end
13 const eos = require('internal/streams/end-of-stream');
97 async function pumpToNode(iterable, writable, finish, { end }) {
141 if (end) {
142 writable.end();
155 async function pumpToWeb(readable, writable, finish, { end }) {
169 if (end) {
256 const end = reading || opts?.end !== false;
260 if (end) {
337 if (end) {
338 pt.end();
348 pumpToNode(ret, pt, finish, { end });
352 pumpToNode(toRead, pt, finish, { end });
369 const cleanup = pipe(ret, stream, finish, { end });
376 pumpToNode(toRead, stream, finish, { end });
379 pumpToNode(ret, stream, finish, { end });
388 pumpToWeb(makeAsyncIterable(ret), stream, finish, { end });
391 pumpToWeb(ret, stream, finish, { end });
394 pumpToWeb(ret.readable, stream, finish, { end });
412 function pipe(src, dst, finish, { end }) {
421 src.pipe(dst, { end: false }); // If end is true we already will have a listener to end dst.
423 if (end) {
425 // pipe() did/does not end() stdio destinations.
430 dst.end();
436 src.once('end', endFn);
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
458 .once('end', finish)