(writer)
| 641 | // otherwise it follows the stream state. The settle sites only touch the |
| 642 | // record when it has been materialized. |
| 643 | function 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 |
no test coverage detected