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

use std::marker::PhantomData;

use futures::Stream;

use crate::{Context, Service};

#[derive(Debug, Clone, Copy)]
pub struct Pass<I, E>(PhantomData<(I, E)>);

impl<I: Send + Sync, E: Send + Sync> Service<I> for Pass<I, E> {
    type Out = Result<I, E>;

    #[inline]
    fn handle(&self, input: I, _cx: &Context) -> impl Stream<Item = Self::Out> + Send {
        futures::stream::once(async move { Ok(input) })
    }
}

#[inline]
pub fn flow<I, E>() -> Pass<I, E> {
    Pass(PhantomData)
}