Function new_node_mempool_worker

crates/node/json-rpc/src/node_mempool_actor.rs:15–34

Worker listens for new transactions in the node mempool and broadcasts [`MessageMempoolDataUpdate`].

(client: P, name: String, mempool_tx: Broadcaster<MessageMempoolDataUpdate>)

/// Worker listens for new transactions in the node mempool and broadcasts [`MessageMempoolDataUpdate`].
pub async fn new_node_mempool_worker<P>(client: P, name: String, mempool_tx: Broadcaster<MessageMempoolDataUpdate>) -> WorkerResult
where
    P: Provider<Ethereum> + Send + Sync + 'static,
{
    let mempool_subscription = client.subscribe_full_pending_transactions().await?;
    let mut stream = mempool_subscription.into_stream();

    while let Some(tx) = stream.next().await {
        let tx_hash: TxHash = tx.tx_hash();
        let update_msg: MessageMempoolDataUpdate = MessageMempoolDataUpdate::new_with_source(
            NodeMempoolDataUpdate { tx_hash, mempool_tx: MempoolTx { tx: Some(tx), ..MempoolTx::default() } },
            name.clone(),
        );
        if let Err(e) = mempool_tx.send(update_msg) {
            error!("mempool_tx.send error : {}", e);
            break;
        }
    }
    Ok(name)
}

#[derive(Producer)]
pub struct NodeMempoolActor<P> {