(self, message, binary=True)
| 69 | self.on_close() |
| 70 | |
| 71 | def write_message(self, message, binary=True): |
| 72 | assert binary |
| 73 | if self._sock is None: |
| 74 | raise OSError("socket is already closed") |
| 75 | self._pending_write.append(message) |
| 76 | self._update_write() |
| 77 | |
| 78 | def _event_handler(self, events): |
| 79 | """centeral event handler""" |