loom_node_player::worker

Function node_player_worker

Source 
pub async fn node_player_worker<P, DB>(
    provider: P,
    start_block: BlockNumber,
    end_block: BlockNumber,
    mempool: Option<SharedState<Mempool>>,
    market_state: Option<SharedState<MarketState<DB>>>,
    new_block_headers_channel: Option<Broadcaster<MessageBlockHeader>>,
    new_block_with_tx_channel: Option<Broadcaster<MessageBlock>>,
    new_block_logs_channel: Option<Broadcaster<MessageBlockLogs>>,
    new_block_state_update_channel: Option<Broadcaster<MessageBlockStateUpdate>>,
) -> WorkerResult
where
    P: Provider<HttpCachedTransport, Ethereum> + DebugProviderExt<HttpCachedTransport, Ethereum> + Send + Sync + Clone + 'static,
    DB: Database + DatabaseRef + DatabaseCommit + Send + Sync + Clone + 'static,