Searched refs:update_pusher_last_stream_ordering (Results 1 – 2 of 2) sorted by relevance
256 await self.store.update_pusher_last_stream_ordering(
199 async def update_pusher_last_stream_ordering( member in PusherWorkerStore