Function stream_compose_networks 

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

Stream Docker network events for a compose project in real-time. Streams Docker events, filters by event_type == "network" and the compose project label, and applies the compose query’s pipeline to each row.