MCPcopy Create free account
hub / github.com/nodejs/node / cleanup

Function cleanup

lib/internal/streams/iter/classic.js:507–517  ·  view source on GitHub ↗
(err)

Source from the content-addressed store, hash-verified

505
506 // Reject all pending waiters and remove the drain/error listeners.
507 function cleanup(err) {
508 const pending = waiters;
509 waiters = [];
510 for (let i = 0; i < pending.length; i++) {
511 pending[i].reject(err ?? new AbortError());
512 }
513 if (!listenersInstalled) return;
514 listenersInstalled = false;
515 writable.removeListener('drain', onDrain);
516 writable.removeListener('error', onError);
517 }
518
519 function waitForDrain() {
520 const { promise, resolve, reject } = PromiseWithResolvers();

Callers 5

endFunction · 0.70
failFunction · 0.70
[SymbolAsyncDispose]Function · 0.70
[SymbolDispose]Function · 0.70

Calls 2

rejectMethod · 0.80
removeListenerMethod · 0.45

Tested by

no test coverage detected