Function collect_events 

pub async fn collect_events<S>(
    query: &EventsQuery,
    source: &S,
) -> Result<ExecutionResult, EventsError>
where
    S: EventSource + ?Sized + Sync,