Write one message to an async writer. Args: writer: asyncio StreamWriter data: Message dictionary to send
(writer, data: dict)
| 157 | |
| 158 | @staticmethod |
| 159 | async def write_message_async(writer, data: dict): |
| 160 | """ |
| 161 | Write one message to an async writer. |
| 162 | |
| 163 | Args: |
| 164 | writer: asyncio StreamWriter |
| 165 | data: Message dictionary to send |
| 166 | """ |
| 167 | message = ControlProtocol.encode_message(data) |
| 168 | writer.write(message) |
| 169 | await writer.drain() |
| 170 | |
| 171 | |
| 172 | def make_request(request_id: int, command: str, args: list = None) -> dict: |