Function stream_logs 

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

Stream log lines in real-time, applying the query pipeline to each row.