Skip to main content

o2m_sender

hydro_test_embedded::o2m_broadcast

Function o2m_sender 

Source 
pub fn o2m_sender<'a, __Mem0: Stream<Item = (TaglessMemberId, MembershipEvent)> + Unpin + 'a, __NetOut0: FnMut((TaglessMemberId, Bytes)) + 'a>(
    __membership: EmbeddedMembershipStreams<__Mem0>,
    input: impl Stream<Item = String> + Unpin + 'a,
    __network_out: &'a mut EmbeddedNetworkOut<__NetOut0>,
) -> Dfir<'a>