Struct AsyncExecutor 

pub struct AsyncExecutor;

Async graph executor using tokio tasks.

Example

use oximedia_graph::async_exec::{AsyncExecutor, AsyncExecutorConfig};
use oximedia_graph::scheduler::ExecutionPlan;

async fn run_graph(plan: ExecutionPlan) {
    let config = AsyncExecutorConfig::default();
    let (results, stats) = AsyncExecutor::run(&plan, config, |node_id| async move {
        // Perform async I/O for this node.
        Ok::<(), String>(())
    }).await;
}

Implementations

impl AsyncExecutor

pub async fn run<F, Fut>( plan: &ExecutionPlan, config: AsyncExecutorConfig, executor: F, ) -> (Vec<ParallelNodeResult>, ParallelRunStats)

where F: Fn(String) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<(), String>> + Send + 'static,

Execute the plan asynchronously.

executor is an async factory that receives a node ID (owned String) and returns a future resolving to Result<(), String>.

Returns the collected per-node results and aggregate statistics.