Skip to main content

m2m_broadcast

Function m2m_broadcast 

Source
pub fn m2m_broadcast<'a>(
    dst: &Cluster<'a, Dst>,
    input: Stream<String, Cluster<'a, Src>>,
) -> Stream<(MemberId<Src>, String), Cluster<'a, Dst>, Unbounded, NoOrder>