Function o2m_broadcast 

pub fn o2m_broadcast<'a>(
    cluster: &Cluster<'a, Dst>,
    input: Stream<String, Process<'a, Src>>,
) -> Stream<String, Cluster<'a, Dst>>