(self)
| 37 | await self._loop.run_in_executor(None, lambda: file.close()) |
| 38 | |
| 39 | async def read_all(self) -> bytes: |
| 40 | binary = b"" |
| 41 | while True: |
| 42 | chunk = await self._channel.send("read", None, {"size": 1024 * 1024}) |
| 43 | if not chunk: |
| 44 | break |
| 45 | binary += base64.b64decode(chunk) |
| 46 | return binary |