Function jormungandr::network::subscription::process_fragments

pub async fn process_fragments<S>(
    stream: S,
    mbox: MessageBox<TransactionMsg>,
    node_id: NodeId,
    global_state: GlobalStateR
)where
    S: TryStream<Ok = Fragment, Error = Error>,