state_change_arb_searcher_worker

kabu_strategy_backrun::state_change_arb_searcher

Function state_change_arb_searcher_worker 

Source 
pub async fn state_change_arb_searcher_worker<DB: DatabaseRef<Error = KabuDBError> + Database<Error = KabuDBError> + DatabaseCommit + Send + Sync + Clone + Default + 'static, LDT: NodePrimitives + 'static>(
    backrun_config: BackrunConfig,
    market: Arc<RwLock<Market>>,
    search_request_rx: Receiver<StateUpdateEvent<DB, LDT>>,
    swap_request_tx: Sender<MessageSwapCompose<DB, LDT>>,
    pool_health_monitor_tx: Sender<MessageHealthEvent>,
    influxdb_write_channel_tx: Option<Sender<WriteQuery>>,
) -> Result<()>