test : fix test error
This commit is contained in:
@@ -14,16 +14,16 @@ describe("authoritative refresh scheduler", () => {
|
||||
const event = { type: "page.updated" as const, id: "page", version: 5 };
|
||||
|
||||
scheduler.connected();
|
||||
await vi.advanceTimersByTimeAsync(25);
|
||||
vi.advanceTimersByTime(25);
|
||||
expect(refresh).toHaveBeenCalledTimes(1);
|
||||
|
||||
scheduler.notified(event);
|
||||
scheduler.notified(event);
|
||||
await vi.advanceTimersByTimeAsync(25);
|
||||
vi.advanceTimersByTime(25);
|
||||
expect(refresh).toHaveBeenCalledTimes(2);
|
||||
|
||||
scheduler.connected();
|
||||
await vi.advanceTimersByTimeAsync(25);
|
||||
vi.advanceTimersByTime(25);
|
||||
expect(refresh).toHaveBeenCalledTimes(3);
|
||||
scheduler.dispose();
|
||||
});
|
||||
|
||||
@@ -42,9 +42,9 @@ describe("SSE stream", () => {
|
||||
expect(decoder.decode((await reader.read()).value)).toBe(
|
||||
"event: deployment\ndata: release-2\n\n",
|
||||
);
|
||||
await vi.advanceTimersByTimeAsync(50);
|
||||
vi.advanceTimersByTime(50);
|
||||
expect(decoder.decode((await reader.read()).value)).toMatch(/^: heartbeat /u);
|
||||
await vi.advanceTimersByTimeAsync(49);
|
||||
vi.advanceTimersByTime(49);
|
||||
expect((await reader.read()).done).toBe(true);
|
||||
expect(onClose).toHaveBeenCalledTimes(1);
|
||||
});
|
||||
|
||||
Reference in New Issue
Block a user