state_change_arb_searcher_task

kabu_strategy_backrun::state_change_arb_searcher

Function state_change_arb_searcher_task 

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