(self, *args, **kwargs)
| 386 | return None |
| 387 | |
| 388 | def open(self, *args, **kwargs): |
| 389 | self.connections.add(self) |
| 390 | self._send_queue = asyncio.Queue() |
| 391 | # Python 3.13+: use _send_queue.shutdown() and we can use keep_ref=True here. |
| 392 | self._send_task = asyncio_utils.create_task( |
| 393 | self.send_task(), |
| 394 | name="WebSocket send task", |
| 395 | keep_ref=False, |
| 396 | ) |
| 397 | |
| 398 | def on_close(self): |
| 399 | self.connections.discard(self) |