@defer.inlineCallbacks
    def get_all_presence_updates(self, last_id, current_id):
        # TODO(markjh): replicate the unpersisted changes.
        # This could use the in-memory stores for recent changes.
        rows = yield self.store.get_all_presence_updates(last_id, current_id)
        defer.returnValue(rows)
Gets a list of presence update rows from between the given stream ids.
dataset/ETHPy150Open matrix-org/synapse/synapse/handlers/presence.py/PresenceHandler.get_all_presence_updates