I think the usecase for this is streaming queries and aggregations where the query output is materialised asynchronously