Searched refs:get_current_topological_token (Results 1 – 2 of 2) sorted by relevance
464 curr_topo = await self.store.get_current_topological_token(
791 async def get_current_topological_token(self, room_id: str, stream_key: int) -> int: member in StreamWorkerStore