From 0f463c98cb3e81d695eeda75568d64210d8f49ea Mon Sep 17 00:00:00 2001 From: Alem Tuzlak Date: Tue, 28 Oct 2025 09:37:45 +0100 Subject: [PATCH 1/2] add higher and configurable reconnect time --- .changeset/plain-eagles-serve.md | 5 +++++ packages/event-bus-client/src/plugin.ts | 5 +++-- 2 files changed, 8 insertions(+), 2 deletions(-) create mode 100644 .changeset/plain-eagles-serve.md diff --git a/.changeset/plain-eagles-serve.md b/.changeset/plain-eagles-serve.md new file mode 100644 index 00000000..a8bd62e1 --- /dev/null +++ b/.changeset/plain-eagles-serve.md @@ -0,0 +1,5 @@ +--- +'@tanstack/devtools-event-client': patch +--- + +increase minimum reconnection time and allow it to be configurable on event bus client diff --git a/packages/event-bus-client/src/plugin.ts b/packages/event-bus-client/src/plugin.ts index 75f871c1..a4dc564b 100644 --- a/packages/event-bus-client/src/plugin.ts +++ b/packages/event-bus-client/src/plugin.ts @@ -64,10 +64,11 @@ export class EventClient< pluginId, debug = false, enabled = true, + reconnectEveryMs = 1000, }: { pluginId: TPluginId debug?: boolean - + reconnectEveryMs?: number enabled?: boolean }) { this.#pluginId = pluginId @@ -78,7 +79,7 @@ export class EventClient< this.#queuedEvents = [] this.#connected = false this.#connectIntervalId = null - this.#connectEveryMs = 500 + this.#connectEveryMs = reconnectEveryMs } private startConnectLoop() { From 23d2b0a307cf16a079f617d1b1e0654743a4c289 Mon Sep 17 00:00:00 2001 From: Alem Tuzlak Date: Tue, 28 Oct 2025 09:43:53 +0100 Subject: [PATCH 2/2] fix tests --- packages/event-bus-client/tests/index.test.ts | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/packages/event-bus-client/tests/index.test.ts b/packages/event-bus-client/tests/index.test.ts index 048ffa4a..f08dd947 100644 --- a/packages/event-bus-client/tests/index.test.ts +++ b/packages/event-bus-client/tests/index.test.ts @@ -208,7 +208,7 @@ describe('EventClient', () => { bus.start() // wait to connect to the bus - await new Promise((resolve) => setTimeout(resolve, 500)) + await new Promise((resolve) => setTimeout(resolve, 1000)) expect(eventHandler).toHaveBeenCalledWith({ type: 'test:event', payload: { foo: 'bar' }, @@ -221,6 +221,7 @@ describe('EventClient', () => { const client = new EventClient({ debug: false, pluginId: 'test', + reconnectEveryMs: 500, }) const eventHandler = vi.fn() client.onAllPluginEvents(eventHandler)