3956d5c6c21dc4b4faec72aff77f0e6b7d85dd45,bokeh/client/connection.py,ClientConnection,_send_message_wait_for_reply,#ClientConnection#Any#,121

Before Change

    def _send_message_wait_for_reply(self, message):
        waiter = self.WAITING_FOR_REPLY(message.header["msgid"])
        self._state = waiter
        self.send_message(message)
        def have_reply_or_disconnected():
            return self._state != waiter or waiter.reply is not None
        self._loop_until(have_reply_or_disconnected)
        return waiter.reply

After Change

        send_result = []
        def message_sent(future):
            send_result.append(future)
        self._loop.add_future(self.send_message(message), message_sent)

        def have_send_result_or_disconnected():
            return len(send_result) > 0 or self._state != waiter

Instances