flowly-service 0.6.0

Flowly is a library of modular and reusable components for building robust pipelines processing audio, video and other.
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

use futures::{FutureExt, Stream};

use crate::{Context, Service};

pub fn and_then<C, F>(f: C) -> AndThenFn<C> {
    AndThenFn { f }
}

#[derive(Clone)]
pub struct AndThenFn<C> {
    pub(crate) f: C,
}

impl<I: Send, O, E, C, F> Service<Result<I, E>> for AndThenFn<C>
where
    F: Future<Output = Result<O, E>> + Send,
    C: Fn(I) -> F + Send + Sync,
    E: std::marker::Send,
{
    type Out = Result<O, E>;

    fn handle(&self, input: Result<I, E>, _cx: &Context) -> impl Stream<Item = Self::Out> + Send {
        async move {
            match input {
                Ok(ok) => (self.f)(ok).await,
                Err(err) => Err(err),
            }
        }
        .into_stream()
    }
}