Function zebrad::components::mempool::gossip::gossip_mempool_transaction_id
source · pub async fn gossip_mempool_transaction_id<ZN>(
receiver: Receiver<HashSet<UnminedTxId>>,
broadcast_network: ZN
) -> Result<(), BoxError>where
ZN: Service<Request, Response = Response, Error = BoxError> + Send + Clone + 'static,
ZN::Future: Send,
Expand description
Runs continuously, gossiping new UnminedTxId
to peers.
Broadcasts any new UnminedTxId
s that get stored in the mempool to multiple ready peers.