loom_strategy_backrun::state_change_arb_searcher

Function state_change_arb_searcher_task

Source
async fn state_change_arb_searcher_task<DB: DatabaseRef<Error = ErrReport> + DatabaseCommit + Send + Sync + Clone + Default + 'static>(
    thread_pool: Arc<ThreadPool>,
    backrun_config: BackrunConfig,
    state_update_event: StateUpdateEvent<DB>,
    market: SharedState<Market>,
    swap_request_tx: Broadcaster<MessageTxCompose<DB>>,
    pool_health_monitor_tx: Broadcaster<MessageHealthEvent>,
) -> Result<()>