Function stream_compose_logs 

pub async fn stream_compose_logs<C, F>(
    query: &ComposeQuery,
    docker: Arc<C>,
    on_row: F,
) -> Result<(), EventsError>
where
    C: DockerClient + Send + Sync + 'static,
    F: FnMut(Row) -> Result<(), EventsError>,

Stream compose service logs in real-time. Finds containers matching the compose project + service, merges their log streams via [futures_util::stream::select_all], and applies the compose query’s pipeline to each row.