(stream4)
| 14151 | return transformPromiseWith(sourceCancelPromise, noop2); |
| 14152 | } |
| 14153 | function ReadableStreamClose(stream4) { |
| 14154 | stream4._state = "closed"; |
| 14155 | const reader = stream4._reader; |
| 14156 | if (reader === void 0) { |
| 14157 | return; |
| 14158 | } |
| 14159 | defaultReaderClosedPromiseResolve(reader); |
| 14160 | if (IsReadableStreamDefaultReader(reader)) { |
| 14161 | const readRequests = reader._readRequests; |
| 14162 | reader._readRequests = new SimpleQueue(); |
| 14163 | readRequests.forEach((readRequest) => { |
| 14164 | readRequest._closeSteps(); |
| 14165 | }); |
| 14166 | } |
| 14167 | } |
| 14168 | function ReadableStreamError(stream4, e3) { |
| 14169 | stream4._state = "errored"; |
| 14170 | stream4._storedError = e3; |
no test coverage detected
searching dependent graphs…