diff --git a/src/wormhole/server/rendezvous_websocket.py b/src/wormhole/server/rendezvous_websocket.py index 7e72813..e37fb6b 100644 --- a/src/wormhole/server/rendezvous_websocket.py +++ b/src/wormhole/server/rendezvous_websocket.py @@ -194,7 +194,7 @@ class WebSocketRendezvous(websocket.WebSocketServerProtocol): def _send(event): self.send("message", message=event) def _stop(): - self._reactor.callLater(0, self.transport.loseConnection) + pass for old_message in self._mailbox.add_listener(self, _send, _stop): _send(old_message)