/** * Await the restart-drain probe only. Callers must then **synchronously** * re-read closing/intakePaused and start run/append/requeue in the same * continuation — no further `await` of a helper that already sampled pause * (that would open a second microtask slot for pause to flip). */ export declare function readRestartDrainActive(isRestartDrainActive?: () => Promise): Promise; //# sourceMappingURL=intake-gate.d.ts.map