bd163732d8c83ad9c643f319d648cccf6dbc185b,lib/streamlit/proxy/ClientWebSocket.py,ClientWebSocket,open,#ClientWebSocket#,37

Before Change

        while True:
            if not self._queue.is_closed():
                yield self._queue.flush_queue(self)
                yield gen.sleep(throttle_secs)

    // @Proxy.stop_proxy_on_exception
    def on_message(self, msg):
        Run callback for websocket messages.

After Change

            if not self._queue.is_closed():
                yield self._queue.flush_queue(self)

            yield gen.sleep(throttle_secs)

        LOGGER.debug(f"Closing loop for "{self._connection.name}"")

    @gen.coroutine

Instances