pub async fn dispatch_lanes<Kind, Lane, Error, F, Fut>(
lane_configs: Vec<TaskLaneConfig<Kind, Lane>>,
lane_parallelism: usize,
dispatch_lane: F,
) -> Result<DispatchStats, Error>where
Kind: Send + Sync + 'static,
Lane: Send + Sync,
F: FnMut(TaskLaneConfig<Kind, Lane>) -> Fut,
Fut: Future<Output = Result<DispatchStats, Error>>,Expand description
Runs lane dispatchers concurrently and aggregates lane statistics.
If one or more lanes fail, the first error is returned after all lanes have completed. This mirrors the existing Yggdrasil and Drive behavior: independent lanes are allowed to finish, then the dispatch pass reports the first lane failure to the caller.