Skip to main content

m2o_sender

hydro_test_embedded::m2o_send

Function m2o_sender 

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