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

use core::pin::Pin;

use cgp::core::Async;
use futures_core::stream::Stream;
use hermes_runtime_components::traits::stream::HasStreamType;

pub trait HasAsyncStreamType: HasStreamType {
    fn from_async_stream<T>(
        stream: Pin<Box<dyn Stream<Item = T> + Send + Sync + 'static>>,
    ) -> Self::Stream<T>
    where
        T: Async;

    fn to_async_stream<T>(
        stream: Self::Stream<T>,
    ) -> Pin<Box<dyn Stream<Item = T> + Send + Sync + 'static>>
    where
        T: Async;
}