flowly-service 0.4.13

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

use super::Context;
use super::Service;
use futures::FutureExt;
use futures::Stream;

use std::marker::PhantomData;

#[derive(Debug, Clone)]
pub struct Inspect<I, F> {
    pub(crate) cb: F,
    pub(crate) _m: PhantomData<I>,
}

impl<I, F> Service<I> for Inspect<I, F>
where
    I: Send,
    F: Send + Fn(&I),
{
    type Out = I;

    fn handle(&mut self, input: I, _cx: &Context) -> impl Stream<Item = Self::Out> + Send {
        async move {
            (self.cb)(&input);
            input
        }
        .into_stream()
    }
}