(self)
| 409 | self._send_queue.put_nowait(message) |
| 410 | |
| 411 | async def send_task(self): |
| 412 | while True: |
| 413 | message = await self._send_queue.get() |
| 414 | try: |
| 415 | await self.write_message(message) |
| 416 | except tornado.websocket.WebSocketClosedError: |
| 417 | self.on_close() |
| 418 | |
| 419 | @staticmethod |
| 420 | def _json_dumps(d): |