2c5cf9c065fdcf0b4b15ab861ed9c0de62a2067f,bokeh/client/states.py,WAITING_FOR_REPLY,run,#WAITING_FOR_REPLY#Any#,108

Before Change

    def run(self, connection):
        message = yield connection._pop_message()
        if message is None:
            yield connection._transition_to_disconnected()
        elif "reqid" in message.header and message.header["reqid"] == self.reqid:
            self._reply = message
            yield connection._transition(CONNECTED_AFTER_ACK())
        else:

After Change

    async def run(self, connection):
        message = await connection._pop_message()
        if message is None:
            return await connection._transition_to_disconnected()
        elif "reqid" in message.header and message.header["reqid"] == self.reqid:
            self._reply = message
            return await connection._transition(CONNECTED_AFTER_ACK())

Instances