()
| 70278 | for await (const event of stream4) { |
| 70279 | __classPrivateFieldGet7(this, _MessageStream_instances, "m", _MessageStream_addStreamEvent).call(this, event); |
| 70280 | } |
| 70281 | if (stream4.controller.signal?.aborted) { |
| 70282 | throw new APIUserAbortError(); |
| 70283 | } |
| 70284 | __classPrivateFieldGet7(this, _MessageStream_instances, "m", _MessageStream_endRequest).call(this); |
| 70285 | } |
| 70286 | _connected() { |
| 70287 | if (this.ended) |
| 70288 | return; |
no test coverage detected