(options?: {
setReadyStatus?: boolean
abortSubscription?: boolean
})
| 598 | } |
| 599 | |
| 600 | private cancelInFlightStream(options?: { |
| 601 | setReadyStatus?: boolean |
| 602 | abortSubscription?: boolean |
| 603 | }): void { |
| 604 | this.abortController?.abort() |
| 605 | this.abortController = null |
| 606 | if (options?.abortSubscription) { |
| 607 | this.abortSubscriptionLoop() |
| 608 | } |
| 609 | this.resolveProcessing() |
| 610 | this.setIsLoading(false) |
| 611 | if (options?.setReadyStatus) { |
| 612 | this.setStatus('ready') |
| 613 | } |
| 614 | } |
| 615 | |
| 616 | private reportStreamError(error: Error): void { |
| 617 | const alreadyReported = |
no test coverage detected