Function start_tx_cache_clearing

fendermint/eth/api/src/mpool.rs:82–91

Subscribe to `NewBlock` notifications and clear transactions from the caches.`

(
    client: FendermintClient<HybridClient>,
    tx_cache: TransactionCache,
    tx_buffer: TransactionBuffer,
)

/// Subscribe to `NewBlock`  notifications and clear transactions from the caches.`
pub fn start_tx_cache_clearing(
    client: FendermintClient<HybridClient>,
    tx_cache: TransactionCache,
    tx_buffer: TransactionBuffer,
) {
    tokio::task::spawn(async move {
        let chain_id = get_chain_id(&client).await;
        tx_cache_clearing_loop(client.into_underlying(), chain_id, tx_cache, tx_buffer).await;
    });
}

/// Subscribe to notifications about new blocks and
/// 1) remove all included transactions from the caches