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

use alloc::boxed::Box;

use cgp::prelude::*;
use futures_util::stream::StreamExt;
use hermes_runtime_components::traits::stream::StreamMapper;

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

pub struct BoxedStreamMapper;

impl<Runtime> StreamMapper<Runtime> for BoxedStreamMapper
where
    Runtime: HasBoxedStreamType,
{
    fn map_stream<T, U, M>(stream: Runtime::Stream<T>, mapper: M) -> Runtime::Stream<U>
    where
        T: Async,
        U: Async,
        M: Fn(T) -> U + Async,
    {
        let mapped = Runtime::to_boxed_stream(stream).map(mapper);

        Runtime::from_boxed_stream(Box::pin(mapped))
    }
}