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

use alloc::sync::Arc;

use cgp::prelude::*;
use hermes_runtime_components::traits::subscription::ProvideSubscription;

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

pub struct ProvideBoxedSubscription;

impl<Runtime> ProvideSubscription<Runtime> for ProvideBoxedSubscription
where
    Runtime: HasBoxedStreamType,
{
    type Subscription<Item: Async> = Arc<dyn Subscription<Item = Item>>;

    async fn subscribe<T>(subscription: &Self::Subscription<T>) -> Option<Runtime::Stream<T>>
    where
        T: Async,
    {
        subscription
            .subscribe()
            .await
            .map(Runtime::from_boxed_stream)
    }
}