Function m2o_send 

pub fn m2o_send<'a>(
    process: &Process<'a, Dst>,
    input: Stream<String, Cluster<'a, Src>>,
) -> Stream<(MemberId<Src>, String), Process<'a, Dst>, Unbounded, NoOrder>