hermes_runtime_components::traits::task

Trait ConcurrentTaskRunner

Source 
pub trait ConcurrentTaskRunner<Runtime>
where
    Runtime: HasStreamType,
{
    // Required methods
    fn run_concurrent_tasks<T>(
        runtime: &Runtime,
        tasks: Vec<T>,
    ) -> impl Future<Output = ()> + Send
       where T: Task;
    fn run_concurrent_task_stream<T>(
        runtime: &Runtime,
        tasks: Runtime::Stream<T>,
    ) -> impl Future<Output = ()> + Send
       where T: Task;
}

Required Methods§

Source

fn run_concurrent_tasks<T>( runtime: &Runtime, tasks: Vec<T>, ) -> impl Future<Output = ()> + Send
where T: Task,

Source

fn run_concurrent_task_stream<T>( runtime: &Runtime, tasks: Runtime::Stream<T>, ) -> impl Future<Output = ()> + Send
where T: Task,

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§

Source§

impl<Component, Runtime> ConcurrentTaskRunner<Runtime> for Component
where Runtime: HasStreamType, Component: DelegateComponent<ConcurrentTaskRunnerComponent>, Component::Delegate: ConcurrentTaskRunner<Runtime>,