hermes-async-runtime-components 0.1.0

Modular runtime components implemented using Tokio
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

use alloc::boxed::Box;
use alloc::vec::Vec;

use futures_util::stream::{self, Stream, StreamExt};
use hermes_runtime_components::traits::task::{ConcurrentTaskRunner, Task};

use crate::stream::traits::boxed::HasBoxedStreamType;

pub struct RunConcurrentTasks;

impl<Runtime> ConcurrentTaskRunner<Runtime> for RunConcurrentTasks
where
    Runtime: HasBoxedStreamType,
{
    async fn run_concurrent_tasks<T>(_runtime: &Runtime, tasks: Vec<T>)
    where
        T: Task,
    {
        run_concurrent_tasks(stream::iter(tasks)).await
    }

    async fn run_concurrent_task_stream<T>(_runtime: &Runtime, tasks: Runtime::Stream<T>)
    where
        T: Task,
    {
        run_concurrent_tasks(Runtime::to_boxed_stream(tasks)).await
    }
}
pub async fn run_concurrent_tasks<T>(tasks: impl Stream<Item = T>)
where
    T: Task,
{
    tasks
        .for_each_concurrent(None, |task| Box::pin(async move { task.run().await }))
        .await;
}