Function jormungandr::network::subscription::process_block_announcements
source · pub async fn process_block_announcements<S>(
stream: S,
mbox: MessageBox<BlockMsg>,
node_id: NodeId,
global_state: GlobalStateR
)where
S: TryStream<Ok = Header, Error = Error>,