MCPcopy Index your code
hub / github.com/nodejs/node / writerClosedPromise

Function writerClosedPromise

lib/internal/webstreams/writablestream.js:643–665  ·  view source on GitHub ↗
(writer)

Source from the content-addressed store, hash-verified

641// otherwise it follows the stream state. The settle sites only touch the
642// record when it has been materialized.
643function writerClosedPromise(writer) {
644 let close = writer[kState].close;
645 if (close === undefined) {
646 const stream = writer[kState].stream;
647 if (stream === undefined) {
648 close = rejectedHandledRecord(lazyWritableReleasedError());
649 } else {
650 switch (stream[kState].state) {
651 case 'writable':
652 case 'erroring':
653 close = PromiseWithResolvers();
654 break;
655 case 'closed':
656 close = resolvedRecord();
657 break;
658 default:
659 close = rejectedHandledRecord(stream[kState].storedError);
660 }
661 }
662 writer[kState].close = close;
663 }
664 return close;
665}
666
667// Same as writerClosedPromise(), for the writer's [[readyPromise]]. The
668// pending epoch is derivable too: a writable stream with backpressure and

Callers 3

closedMethod · 0.85
[kInspect]Method · 0.85
readableStreamPipeToFunction · 0.85

Calls 3

rejectedHandledRecordFunction · 0.85
resolvedRecordFunction · 0.85

Tested by

no test coverage detected