(stream)
| 941 | } |
| 942 | |
| 943 | function writableStreamAddWriteRequest(stream) { |
| 944 | assert(isWritableStreamLocked(stream)); |
| 945 | assert(stream[kState].state === 'writable'); |
| 946 | // PromiseWithResolvers() already returns a { promise, resolve, reject } |
| 947 | // record, so push it as-is instead of rebuilding an identical object. |
| 948 | const writeRequest = PromiseWithResolvers(); |
| 949 | ArrayPrototypePush(stream[kState].writeRequests, writeRequest); |
| 950 | return writeRequest.promise; |
| 951 | } |
| 952 | |
| 953 | function writableStreamDefaultWriterWrite(writer, chunk) { |
| 954 | const { |
no test coverage detected