Function same_path_merger_task

async fn same_path_merger_task<P, T, N, DB>(
    client: P,
    stuffing_txes: Vec<Transaction>,
    pre_states: Arc<RwLock<DataFetcher<TxHash, GethStateUpdate>>>,
    market_state: SharedState<MarketState<DB>>,
    call_opts: GethDebugTracingCallOptions,
    request: TxComposeData<DB>,
    swap_request_tx: Broadcaster<MessageTxCompose<DB>>,
) -> Result<()>
where
    N: Network,
    T: Transport + Clone,
    P: Provider<T, N> + DebugProviderExt<T, N> + Send + Sync + Clone + 'static,
    DB: Database<Error = ErrReport> + DatabaseRef<Error = ErrReport> + DatabaseCommit + Send + Sync + Clone + 'static,