atomr-streams 0.6.0

Typed reactive streams DSL for atomr — Source / Flow / Sink, junctions, framing, kill switches, hubs, stream refs.
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

//! RunnableGraph — a `Source` + terminal `Sink` waiting to be materialized.

use std::future::Future;

use crate::source::Source;

pub struct RunnableGraph<M> {
    runner: Box<dyn FnOnce() -> futures::future::BoxFuture<'static, M> + Send + 'static>,
}

impl<M: Send + 'static> RunnableGraph<M> {
    pub fn new<F, Fut>(f: F) -> Self
    where
        F: FnOnce() -> Fut + Send + 'static,
        Fut: Future<Output = M> + Send + 'static,
    {
        use futures::FutureExt;
        RunnableGraph { runner: Box::new(move || f().boxed()) }
    }

    pub async fn run(self) -> M {
        (self.runner)().await
    }
}

impl<T: Send + 'static> RunnableGraph<Vec<T>> {
    pub fn to_seq(source: Source<T>) -> Self {
        Self::new(move || crate::sink::Sink::collect(source))
    }
}