()
| 510 | const reader = stream.getReader(); |
| 511 | let finished = false; |
| 512 | const finish = () => { |
| 513 | if (finished) return; |
| 514 | finished = true; |
| 515 | try { |
| 516 | reader.releaseLock(); |
| 517 | } catch {} |
| 518 | try { |
| 519 | onDone(); |
| 520 | } catch { |
| 521 | // Disposer failures cannot be recovered at this boundary. |
| 522 | } |
| 523 | }; |
| 524 | return new ReadableStream<T>( |
| 525 | { |
| 526 | async pull(controller) { |
no outgoing calls
no test coverage detected