]> git.ipfire.org Git - thirdparty/tornado.git/commitdiff
Remove WebSocketHandler.stream. 2948/head
authorEugene Toder <eltoder@gmail.com>
Tue, 3 Nov 2020 03:04:00 +0000 (22:04 -0500)
committerEugene Toder <eltoder@gmail.com>
Sun, 10 Jan 2021 06:21:37 +0000 (01:21 -0500)
It was no longer used and always set to None.

tornado/websocket.py

index d2c6a427aacad25ac56248ddbabd588af03ec85f..dfa36554bbf15f3f77421871dc04f6a652ee7884 100644 (file)
@@ -225,7 +225,6 @@ class WebSocketHandler(tornado.web.RequestHandler):
         self.ws_connection = None  # type: Optional[WebSocketProtocol]
         self.close_code = None  # type: Optional[int]
         self.close_reason = None  # type: Optional[str]
-        self.stream = None  # type: Optional[IOStream]
         self._on_close_called = False
 
     async def get(self, *args: Any, **kwargs: Any) -> None:
@@ -584,16 +583,6 @@ class WebSocketHandler(tornado.web.RequestHandler):
         if self.get_status() != 101 or self._on_close_called:
             super()._break_cycles()
 
-    def send_error(self, *args: Any, **kwargs: Any) -> None:
-        if self.stream is None:
-            super().send_error(*args, **kwargs)
-        else:
-            # If we get an uncaught exception during the handshake,
-            # we have no choice but to abruptly close the connection.
-            # TODO: for uncaught exceptions after the handshake,
-            # we can close the connection more gracefully.
-            self.stream.close()
-
     def get_websocket_protocol(self) -> Optional["WebSocketProtocol"]:
         websocket_version = self.request.headers.get("Sec-WebSocket-Version")
         if websocket_version in ("7", "8", "13"):