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

//! BidiFlow — composed of two flows in opposite directions.

use crate::flow::Flow;

pub struct BidiFlow<In1, Out1, In2, Out2> {
    pub forward: Flow<In1, Out1>,
    pub backward: Flow<In2, Out2>,
}

impl<In1, Out1, In2, Out2> BidiFlow<In1, Out1, In2, Out2>
where
    In1: Send + 'static,
    Out1: Send + 'static,
    In2: Send + 'static,
    Out2: Send + 'static,
{
    pub fn from_flows(forward: Flow<In1, Out1>, backward: Flow<In2, Out2>) -> Self {
        Self { forward, backward }
    }
}