Skip to content

Commit 05f5aa0

Browse files
authored
Fix max listener warning from livequery server (#7083)
* fix max listner warning * fix * Clean test log
1 parent 41a052c commit 05f5aa0

File tree

2 files changed

+5
-0
lines changed

2 files changed

+5
-0
lines changed

spec/EnableExpressErrorHandler.spec.js

+1
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@ const request = require('../lib/request');
22

33
describe('Enable express error handler', () => {
44
it('should call the default handler in case of error, like updating a non existing object', async done => {
5+
spyOn(console, 'error');
56
const parseServer = await reconfigureServer(
67
Object.assign({}, defaultConfiguration, {
78
enableExpressErrorHandler: true,

src/Adapters/PubSub/EventEmitterPubSub.js

+4
Original file line numberDiff line numberDiff line change
@@ -46,6 +46,10 @@ function createPublisher(): any {
4646
}
4747

4848
function createSubscriber(): any {
49+
// createSubscriber is called once at live query server start
50+
// to avoid max listeners warning, we should clean up the event emitter
51+
// each time this function is called
52+
emitter.removeAllListeners();
4953
return new Subscriber(emitter);
5054
}
5155

0 commit comments

Comments
 (0)