50c87bd8a64ced239cf0e3e12fa0d78de9895574,lib/streamlit/Proxy/websocket.py,ClientWebSocket,open,#ClientWebSocket#,14

Before Change

        throttle_secs = config.get_option("local.throttleSecs")

        // Manages our connection to the local client.
        connection, queue = None, None

        LOGGER.info("Browser websocket opened for "{}"".format(report_name))

    def on_message(self, msg):

After Change

        yield new_report_msg(self._connection.id, self)

        LOGGER.info("Browser websocket opened for "{}"".format(self._report_name))
        while True:
            if not self._queue.is_closed():
                yield self._queue.flush_queue(self)
                yield gen.sleep(throttle_secs)

    def on_message(self, msg):
        data = json.loads(msg)
        payload = json.dumps(data)
        self.write_message(payload, binary=False)

Instances