| 30 | export interface StreamSource { |
| 31 | envelopes(): AsyncGenerator<Envelope>; |
| 32 | } |
| 33 | |
| 34 | const STREAM_ERROR_NAMES: Record<number, string> = { |
| 35 | [AskStreamErrorCode.UNSPECIFIED]: "unspecified", |
| 36 | [AskStreamErrorCode.MACHINE_OFFLINE]: "machine_offline", |
| 37 | [AskStreamErrorCode.NO_TARGETS]: "no_targets", |
| 38 | [AskStreamErrorCode.INTERNAL]: "internal", |
| 39 | [AskStreamErrorCode.PIN_DENIED]: "pin_denied", |
| 40 | }; |
| 41 | |
| 42 | export class AskStream implements AsyncIterable<AskFrame> { |
no outgoing calls
no test coverage detected