same_path_merger_worker

kabu_strategy_merger::samepath_merger_actor

Function same_path_merger_worker 

Source 
async fn same_path_merger_worker<N: Network<TransactionRequest = TransactionRequest>, P: Provider<N> + DebugProviderExt<N> + Send + Sync + Clone + 'static, DB: DatabaseRef<Error = KabuDBError> + Database<Error = KabuDBError> + DatabaseCommit + Send + Sync + Clone + 'static>(
    client: P,
    market_state: Arc<RwLock<MarketState<DB>>>,
    market_events_rx: Receiver<MarketEvents>,
    compose_channel_rx: Receiver<MessageSwapCompose<DB>>,
    compose_channel_tx: Sender<MessageSwapCompose<DB>>,
)