same_path_merger_task

kabu_strategy_merger::samepath_merger_actor

Function same_path_merger_task 

Source 
async fn same_path_merger_task<P, N, DB, NP>(
    client: P,
    stuffing_txes: Vec<NP::SignedTx>,
    pre_states: Arc<RwLock<DataFetcher<TxHash, GethStateUpdate>>>,
    market_state: Arc<RwLock<MarketState<DB>>>,
    call_opts: GethDebugTracingCallOptions,
    request: SwapComposeData<DB, NP>,
    swap_request_tx: Sender<MessageSwapCompose<DB, NP>>,
) -> Result<()>
where
    N: Network<TransactionRequest = TransactionRequest>,
    P: Provider<N> + DebugProviderExt<N> + Send + Sync + Clone + 'static,
    DB: Database<Error = KabuDBError> + DatabaseRef<Error = KabuDBError> + DatabaseCommit + Send + Sync + Clone + 'static,
    NP: NodePrimitives,