e0e9d7350826c7d968e48181cea38bde23942c30,lib/streamlit/Server.py,Server,loop_coroutine,#Server#,143

Before Change

                for ws, browser_queue in ws_queue_pairs:
                    msg_list = browser_queue.flush()
                    for msg in msg_list:
                        msg_str = _serialize(msg)
                        if ws is None:
                            break
                        try:
                            ws.write_message(msg_str, binary=True)
                        except tornado.websocket.WebSocketClosedError:
                            self._remove_browser_connection(ws)
                        yield
                    yield

            elif self._state == State.NO_BROWSERS_CONNECTED:
                pass

After Change

            yield tornado.gen.sleep(0.01)

        // Shut down all ReportContexts
        for report_ctx in list(self._report_contexts.values()):
            report_ctx.shutdown()

        self._set_state(State.STOPPED)

        // Stop the ioloop. This will end our process.
        self._ioloop.stop()

Instances