Searched refs:get_all_new_events_stream (Results 1 – 2 of 2) sorted by relevance
338 next_token, events = await self.store.get_all_new_events_stream(
947 async def get_all_new_events_stream( member in StreamWorkerStore