| 67 | |
| 68 | class AskStream: |
| 69 | def __init__(self, transport: Transport, request: pb.Envelope, timeout_ms: int) -> None: |
| 70 | self._transport = transport |
| 71 | self._request = request |
| 72 | self._timeout = timeout_ms / 1000 |
| 73 | self._started = False |
| 74 | |
| 75 | async def __aiter__(self) -> AsyncIterator[AskFrame]: |
| 76 | if self._started: |
no outgoing calls
no test coverage detected