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

Function writerReadyPromise

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

Source from the content-addressed store, hash-verified

668// pending epoch is derivable too: a writable stream with backpressure and
669// no queued close has a pending ready promise.
670function writerReadyPromise(writer) {
671 let ready = writer[kState].ready;
672 if (ready === undefined) {
673 const stream = writer[kState].stream;
674 if (stream === undefined) {
675 ready = rejectedHandledRecord(lazyWritableReleasedError());
676 } else {
677 switch (stream[kState].state) {
678 case 'writable':
679 ready = !writableStreamCloseQueuedOrInFlight(stream) &&
680 stream[kState].backpressure ?
681 PromiseWithResolvers() :
682 resolvedRecord();
683 break;
684 case 'closed':
685 ready = resolvedRecord();
686 break;
687 default:
688 ready = rejectedHandledRecord(stream[kState].storedError);
689 }
690 }
691 writer[kState].ready = ready;
692 }
693 return ready;
694}
695
696function writableStreamAbort(stream, reason) {
697 const {

Callers 3

readyMethod · 0.85
[kInspect]Method · 0.85
stepFunction · 0.85

Calls 4

rejectedHandledRecordFunction · 0.85
resolvedRecordFunction · 0.85

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…