loom_node_exex::reth_exex_worker

Function process_chain

Source
async fn process_chain(
    chain: Arc<Chain>,
    block_header_channel: Broadcaster<MessageBlockHeader>,
    block_with_tx_channel: Broadcaster<MessageBlock>,
    logs_channel: Broadcaster<MessageBlockLogs>,
    state_update_channel: Broadcaster<MessageBlockStateUpdate>,
    config: &NodeBlockActorConfig,
) -> Result<()>