zebrad::components::mempool::gossip

Function 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 UnminedTxIds that get stored in the mempool to multiple ready peers.