@@ -363,7 +363,7 @@ describe("createInboundDebouncer", () => {
363363it("keeps later same-key work behind a timer-backed flush that already started", async () => {
364364const started: string[] = [];
365365const finished: string[] = [];
366-let releaseFirst!: () => void;
366+let releaseFirst: (() => void) | undefined;
367367const firstGate = new Promise<void>((resolve) => {
368368releaseFirst = resolve;
369369});
@@ -404,6 +404,9 @@ describe("createInboundDebouncer", () => {
404404expect(started).toEqual(["1"]);
405405expect(finished).toEqual([]);
406406407+if (!releaseFirst) {
408+throw new Error("Expected first inbound debounce release callback to be initialized");
409+}
407410releaseFirst();
408411await Promise.all([firstFlush, secondEnqueue]);
409412@@ -417,7 +420,7 @@ describe("createInboundDebouncer", () => {
417420it("keeps fire-and-forget keyed work ahead of a later buffered item", async () => {
418421const started: string[] = [];
419422const finished: string[] = [];
420-let releaseFirst!: () => void;
423+let releaseFirst: (() => void) | undefined;
421424const firstGate = new Promise<void>((resolve) => {
422425releaseFirst = resolve;
423426});
@@ -472,6 +475,9 @@ describe("createInboundDebouncer", () => {
472475expect(started).toEqual(["1"]);
473476expect(finished).toEqual([]);
474477478+if (!releaseFirst) {
479+throw new Error("Expected first inbound debounce release callback to be initialized");
480+}
475481releaseFirst();
476482await Promise.all([firstFlush, secondEnqueue, thirdFlush, thirdEnqueue]);
477483@@ -484,7 +490,7 @@ describe("createInboundDebouncer", () => {
484490485491it("does not serialize keyed turns when debounce is disabled and no keyed chain exists", async () => {
486492const started: string[] = [];
487-let releaseFirst!: () => void;
493+let releaseFirst: (() => void) | undefined;
488494const firstGate = new Promise<void>((resolve) => {
489495releaseFirst = resolve;
490496});
@@ -508,6 +514,9 @@ describe("createInboundDebouncer", () => {
508514509515expect(started).toEqual(["1", "2"]);
510516517+if (!releaseFirst) {
518+throw new Error("Expected first inbound debounce release callback to be initialized");
519+}
511520releaseFirst();
512521await Promise.all([first, second]);
513522});
@@ -582,7 +591,7 @@ describe("createInboundDebouncer", () => {
582591it("keeps same-key overflow work ordered after falling back to immediate flushes", async () => {
583592const started: string[] = [];
584593const finished: string[] = [];
585-let releaseOverflow!: () => void;
594+let releaseOverflow: (() => void) | undefined;
586595const overflowGate = new Promise<void>((resolve) => {
587596releaseOverflow = resolve;
588597});
@@ -632,6 +641,9 @@ describe("createInboundDebouncer", () => {
632641expect(started).toEqual(["2"]);
633642expect(finished).toEqual([]);
634643644+if (!releaseOverflow) {
645+throw new Error("Expected inbound overflow release callback to be initialized");
646+}
635647releaseOverflow();
636648await Promise.all([overflowEnqueue, bufferedEnqueue, bufferedFlush]);
637649@@ -645,7 +657,7 @@ describe("createInboundDebouncer", () => {
645657it("counts tracked debounce keys by union of buffers and active chains", async () => {
646658const started: string[] = [];
647659const finished: string[] = [];
648-let releaseChainOnly!: () => void;
660+let releaseChainOnly: (() => void) | undefined;
649661const chainOnlyGate = new Promise<void>((resolve) => {
650662releaseChainOnly = resolve;
651663});
@@ -707,6 +719,9 @@ describe("createInboundDebouncer", () => {
707719expect(finished).toEqual(["4"]);
708720});
709721722+if (!releaseChainOnly) {
723+throw new Error("Expected inbound chain-only release callback to be initialized");
724+}
710725releaseChainOnly();
711726await Promise.all([secondFlush, overflowEnqueue]);
712727expect(finished).toEqual(["4", "2"]);
此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。