loom_strategy_merger::samepath_merger_actor

Function same_path_merger_worker

Source 
async fn same_path_merger_worker<T: Transport + Clone, N: Network, P: Provider<T, N> + DebugProviderExt<T, N> + Send + Sync + Clone + 'static, DB: DatabaseRef<Error = ErrReport> + Database<Error = ErrReport> + DatabaseCommit + Send + Sync + Clone + 'static>(
    client: P,
    latest_block: SharedState<LatestBlock>,
    market_state: SharedState<MarketState<DB>>,
    market_events_rx: Broadcaster<MarketEvents>,
    compose_channel_rx: Broadcaster<MessageTxCompose<DB>>,
    compose_channel_tx: Broadcaster<MessageTxCompose<DB>>,
) -> WorkerResult