Lines Matching defs:finish
97 async function pumpToNode(iterable, writable, finish, { end }) {
146 finish();
148 finish(error !== err ? aggregateTwoErrors(error, err) : err);
155 async function pumpToWeb(readable, writable, finish, { end }) {
173 finish();
177 finish(err);
179 finish(err);
223 function finish(err) {
276 finish(err);
340 process.nextTick(finish);
343 process.nextTick(finish, err);
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 }) {
417 finish(new ERR_STREAM_PREMATURE_CLOSE());
439 finish();
458 .once('end', finish)
459 .once('error', finish);
461 finish(err);
464 return eos(dst, { readable: false, writable: true }, finish);