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

use futures::{Stream, StreamExt};

use crate::Service;

#[derive(Debug, Clone)]
pub struct Optional<S> {
    pub(crate) service: Option<S>,
}

impl<I, S: Service<I, Out = I>> Service<I> for Optional<S> {
    type Out = I;

    fn handle(self, input: impl Stream<Item = I> + Send) -> impl Stream<Item = Self::Out> + Send {
        if let Some(srv) = self.service {
            srv.handle(input).left_stream()
        } else {
            input.right_stream()
        }
    }
}