pub fn o2m_receiver<'a, __Out0: FnMut(String) + 'a, __NetIn0: Stream<Item = Result<BytesMut, Error>> + Unpin + 'a>(
__cluster_self_id: &'a TaglessMemberId,
__outputs: &'a mut EmbeddedOutputs<__Out0>,
__network_in: EmbeddedNetworkIn<__NetIn0>,
) -> Dfir<'a>