arb_swap_path_merger_worker

kabu_strategy_merger::swappath_merger_actor

Function arb_swap_path_merger_worker 

Source 
async fn arb_swap_path_merger_worker<N: NodeTypesWithDB, R: BlockNumReader + HeaderProvider<Header = HeaderTy<N>> + Send + Sync + Clone + 'static, DB: DatabaseRef<Error = KabuDBError> + Database<Error = KabuDBError> + DatabaseCommit + Send + Sync + Clone + 'static>(
    provider: R,
    multicaller_address: Address,
    market_events_rx: Sender<MarketEvents>,
    compose_channel_rx: Sender<MessageSwapCompose<DB>>,
    compose_channel_tx: Sender<MessageSwapCompose<DB>>,
) -> Result<()>
where
    HeaderTy<N>: BlockHeader,