Function stream_events 

pub async fn stream_events<S, F>(
    query: &EventsQuery,
    source: &S,
    on_row: F,
) -> Result<(), EventsError>
where
    S: EventSource + ?Sized + Sync,
    F: FnMut(Row) -> Result<(), EventsError>,