Function gossip_server::setup_inbound_deserialization

source ยท 
pub(crate) fn setup_inbound_deserialization<Inbound, Message>(
    inbound: Inbound,
) -> impl Stream<Item = (Message, SocketAddr)>
where
    Inbound: Stream<Item = Result<(BytesMut, SocketAddr), Error>>,
    Message: for<'de> Deserialize<'de> + Debug + Send + 'static,
Expand description

Setup deserialization for inbound networking messages.