Function erdos::dataflow::connect::connect_one_in_two_out

pub fn connect_one_in_two_out<O, S, T, U, V>(
    operator_fn: impl Fn() -> O + Clone + Send + Sync + 'static, 
    state_fn: impl Fn() -> S + Clone + Send + Sync + 'static, 
    config: OperatorConfig, 
    read_stream: &dyn Stream<T>
) -> (OperatorStream<U>, OperatorStream<V>) where
    O: 'static + OneInTwoOut<S, T, U, V>,
    S: State,
    T: Data + for<'a> Deserialize<'a>,
    U: Data + for<'a> Deserialize<'a>,
    V: Data + for<'a> Deserialize<'a>, 

Adds a OneInTwoOut operator that has one input read stream and two output write streams.