Function reth::rpc::server_types::eth::cache::cache_new_blocks_task
pub async fn cache_new_blocks_task<St>(
eth_state_cache: EthStateCache,
events: St,
)where
St: Stream<Item = CanonStateNotification> + Unpin + '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.
Reorged blocks are removed from the cache.