(rejected, error)
| 1496 | // tells us that the promise must be rejected even |
| 1497 | // when error is undefine. |
| 1498 | function finalize(rejected, error) { |
| 1499 | writableStreamDefaultWriterRelease(writer); |
| 1500 | readableStreamReaderGenericRelease(reader); |
| 1501 | if (signal !== undefined) |
| 1502 | disposable?.[SymbolDispose](); |
| 1503 | if (rejected) |
| 1504 | promise.reject(error); |
| 1505 | else |
| 1506 | promise.resolve(); |
| 1507 | } |
| 1508 | |
| 1509 | async function waitForCurrentWrite() { |
| 1510 | const write = state.currentWrite; |
no test coverage detected
searching dependent graphs…