logo

Function zebrad::components::mempool::gossip::gossip_mempool_transaction_id[][src]

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

Run continuously, gossiping new zebra_chain::transaction::UnminedTxId to peers.

Broadcast any [transaction::UnminedTxId] that gets stored in the mempool to all ready peers.