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: KabuDataTypesEVM>(
    thread_pool: Arc<ThreadPool>,
    backrun_config: BackrunConfig,
    state_update_event: StateUpdateEvent<DB, LDT>,
    market: SharedState<Market>,
    swap_request_tx: Broadcaster<MessageSwapCompose<DB, LDT>>,
    pool_health_monitor_tx: Broadcaster<MessageHealthEvent>,
    influxdb_write_channel_tx: Broadcaster<WriteQuery>,
) -> Result<()>