diff --git a/src/LiveQueryClient.js b/src/LiveQueryClient.js index 2ad463543..cdcfe2efc 100644 --- a/src/LiveQueryClient.js +++ b/src/LiveQueryClient.js @@ -381,7 +381,7 @@ class LiveQueryClient extends EventEmitter { if (data.requestId) { if (subscription) { subscription.subscribePromise.resolve(); - subscription.emit(SUBSCRIPTION_EMMITER_TYPES.ERROR, data.error); + setTimeout(() => subscription.emit(SUBSCRIPTION_EMMITER_TYPES.ERROR, data.error), 200); } } else { this.emit(CLIENT_EMMITER_TYPES.ERROR, data.error); diff --git a/src/__tests__/LiveQueryClient-test.js b/src/__tests__/LiveQueryClient-test.js index 476fdcb0f..844620c49 100644 --- a/src/__tests__/LiveQueryClient-test.js +++ b/src/__tests__/LiveQueryClient-test.js @@ -244,6 +244,7 @@ describe('LiveQueryClient', () => { liveQueryClient._handleWebSocketMessage(event); + jest.runOnlyPendingTimers(); expect(isChecked).toBe(true); });