(value: Any)
| 188 | message_queue: AsyncQueue[str] = AsyncQueue() |
| 189 | |
| 190 | async def send(value: Any) -> None: |
| 191 | await self.write_message(json.dumps(value)) |
| 192 | |
| 193 | async def recv() -> Any: |
| 194 | return json.loads(await message_queue.get()) |
no outgoing calls
no test coverage detected