Function reth::rpc::server_types::eth::fee_history::fee_history_cache_new_blocks_task

source · 
pub async fn fee_history_cache_new_blocks_task<St, Provider>(
    fee_history_cache: FeeHistoryCache,
    events: St,
    provider: Provider,
)
where
    St: Stream<Item = CanonStateNotification> + Unpin + 'static,
    Provider: BlockReaderIdExt + ChainSpecProvider + 'static,
Expand description

Awaits for new chain events and directly inserts them into the cache so they’re available immediately before they need to be fetched from disk.