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() { 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)