(self)
| 161 | self.on_data(message) |
| 162 | |
| 163 | def on_close(self): |
| 164 | logging.info("RPCProxy: on_close %s ...", self.name()) |
| 165 | self._close_process = True |
| 166 | |
| 167 | if self.forward_proxy: |
| 168 | self.forward_proxy.signal_close() |
| 169 | self.forward_proxy = None |
| 170 | self.on_close_event() |
| 171 | |
| 172 | |
| 173 | class WebSocketHandler(websocket.WebSocketHandler, ForwardHandler): |
no test coverage detected