dfeb023bac22ae77a08b917c297a03de1e2da9eb,local/server/streamlit/local/Proxy.py,Proxy,_client_ws_handler,#Proxy#Any#,247

Before Change

                    pass
            print("Received the close message for "%s". Now removing the final queue." % report_name)
        except concurrent.futures.CancelledError:
            print("CancelledError in _client_ws_handler")
            pass

        if connection != None:
            self._remove_client(connection, queue)

After Change

                try:
                    msg = await ws.receive(timeout=throttle_secs)
                    if msg.type != WSMsgType.CLOSE:
                        raise RuntimeError(f"Unknown message type: {msg.type}")
                    break
                except asyncio.TimeoutError:
                    pass
        except concurrent.futures.CancelledError:

Instances