@@ -555,9 +555,7 @@ describe("createInboundDebouncer", () => {
555555clearTimeout(
556556setTimeoutSpy.mock.results[firstTimerIndex]?.value as ReturnType<typeof setTimeout>,
557557);
558-const firstFlush = (
559-setTimeoutSpy.mock.calls[firstTimerIndex]?.[0] as (() => Promise<void>) | undefined
560-)?.();
558+(setTimeoutSpy.mock.calls[firstTimerIndex]?.[0] as (() => void) | undefined)?.();
561559562560await vi.waitFor(() => {
563561expect(started).toEqual(["1"]);
@@ -573,9 +571,7 @@ describe("createInboundDebouncer", () => {
573571clearTimeout(
574572setTimeoutSpy.mock.results[thirdTimerIndex]?.value as ReturnType<typeof setTimeout>,
575573);
576-const thirdFlush = (
577-setTimeoutSpy.mock.calls[thirdTimerIndex]?.[0] as (() => Promise<void>) | undefined
578-)?.();
574+(setTimeoutSpy.mock.calls[thirdTimerIndex]?.[0] as (() => void) | undefined)?.();
579575580576await Promise.resolve();
581577@@ -586,10 +582,12 @@ describe("createInboundDebouncer", () => {
586582throw new Error("Expected first inbound debounce release callback to be initialized");
587583}
588584releaseFirst();
589-await Promise.all([firstFlush, secondEnqueue, thirdFlush, thirdEnqueue]);
585+await Promise.all([secondEnqueue, thirdEnqueue]);
590586591-expect(started).toEqual(["1", "2", "3"]);
592-expect(finished).toEqual(["1", "2", "3"]);
587+await vi.waitFor(() => {
588+expect(started).toEqual(["1", "2", "3"]);
589+expect(finished).toEqual(["1", "2", "3"]);
590+});
593591} finally {
594592setTimeoutSpy.mockRestore();
595593}
@@ -775,9 +773,7 @@ describe("createInboundDebouncer", () => {
775773clearTimeout(
776774setTimeoutSpy.mock.results[bufferedTimerIndex]?.value as ReturnType<typeof setTimeout>,
777775);
778-const bufferedFlush = (
779-setTimeoutSpy.mock.calls[bufferedTimerIndex]?.[0] as (() => Promise<void>) | undefined
780-)?.();
776+(setTimeoutSpy.mock.calls[bufferedTimerIndex]?.[0] as (() => void) | undefined)?.();
781777782778await Promise.resolve();
783779expect(started).toEqual(["2"]);
@@ -787,10 +783,12 @@ describe("createInboundDebouncer", () => {
787783throw new Error("Expected inbound overflow release callback to be initialized");
788784}
789785releaseOverflow();
790-await Promise.all([overflowEnqueue, bufferedEnqueue, bufferedFlush]);
786+await Promise.all([overflowEnqueue, bufferedEnqueue]);
791787792-expect(started).toEqual(["2", "3"]);
793-expect(finished).toEqual(["2", "3"]);
788+await vi.waitFor(() => {
789+expect(started).toEqual(["2", "3"]);
790+expect(finished).toEqual(["2", "3"]);
791+});
794792} finally {
795793setTimeoutSpy.mockRestore();
796794}
此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。