(stream)
| 2392 | return pendingAbortRequest.promise; |
| 2393 | } |
| 2394 | function WritableStreamClose(stream) { |
| 2395 | let state = stream.state; |
| 2396 | if ((state == "closed") || (state == "errored")) |
| 2397 | return Promise.reject(new TypeError("stream already closed or errored")); |
| 2398 | assert((state == "writable") || (state == "erroring")); |
| 2399 | assert(WritableStreamCloseQueuedOrInFlight(stream) === false); |
| 2400 | let closeRequest = createPromise(); |
| 2401 | stream.closeRequest = closeRequest; |
| 2402 | let writer = stream.writer; |
| 2403 | if ((writer !== undefined) && stream.backpressure && (state == "writable")) |
| 2404 | resolvePromise(writer.readyPromise, undefined); |
| 2405 | WritableStreamDefaultControllerClose(stream.controller); |
| 2406 | return closeRequest.promise; |
| 2407 | } |
| 2408 | |
| 2409 | // 5.5.2 Interfacing with controllers |
| 2410 | function WritableStreamAddWriteRequest(stream) { |
no test coverage detected