diff_path_merger_worker

kabu_strategy_merger::diffpath_merger_actor

Function diff_path_merger_worker 

Source 
async fn diff_path_merger_worker<DB>(
    market_events_rx: Sender<MarketEvents>,
    compose_channel_rx: Sender<MessageSwapCompose<DB>>,
    compose_channel_tx: Sender<MessageSwapCompose<DB>>,
) -> Result<()>
where
    DB: DatabaseRef + Database + DatabaseCommit + Send + Sync + Clone + 'static,