Skip to main content

queue_drain_loop

Function queue_drain_loop 

Source
pub async fn queue_drain_loop(
    queue: Arc<RequestQueue>,
    state: Arc<AppState>,
    cancel: CancellationToken,
)
Expand description

Background drain loop that processes queued requests as capacity becomes available.

Watches for backend capacity, dequeues requests, re-runs the reconciler pipeline, and sends responses via oneshot channels.