(self)
| 68 | ) |
| 69 | |
| 70 | async def read_info_buffer(self) -> bytes: |
| 71 | stream = cast( |
| 72 | Stream, |
| 73 | from_channel( |
| 74 | await self._channel.send( |
| 75 | "stream", |
| 76 | None, |
| 77 | ) |
| 78 | ), |
| 79 | ) |
| 80 | buffer = await stream.read_all() |
| 81 | return buffer |
| 82 | |
| 83 | async def cancel(self) -> None: # pyright: ignore[reportIncompatibleMethodOverride] |
| 84 | await self._channel.send( |
no test coverage detected