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.