set setMaxListeners(Infinity)

src/ObservedCall.ts

@@ -38,6 +38,7 @@ export class ObservedCall<AppData extends Record<string, unknown> = Record<strin
 		public readonly appData: AppData,
 	) {
 		super();
+		this.setMaxListeners(Infinity);
 	}
 
 	public get serviceId(): string {

src/ObservedClient.ts

@@ -95,6 +95,7 @@ export class ObservedClient<AppData extends Record<string, unknown> = Record<str
 		public readonly appData: AppData
 	) {
 		super();
+		this.setMaxListeners(Infinity);
 	}
 
 	public get clientId(): string {

src/ObservedDataChannel.ts

@@ -65,6 +65,7 @@ export class ObservedDataChannel extends EventEmitter	{
 		public readonly peerConnection: ObservedPeerConnection,
 	) {
 		super();
+		this.setMaxListeners(Infinity);
 	}
 
 	public get serviceId() {

src/ObservedICE.ts

@@ -40,6 +40,7 @@ export class ObservedICE extends EventEmitter {
 		public readonly peerConnection: ObservedPeerConnection,
 	) {
 		super();
+		this.setMaxListeners(Infinity);
 	}
 
 	public get reports() {
@@ -147,7 +148,7 @@ export class ObservedICE extends EventEmitter {
 		if (!candidatePair.nominated) return;
 
 		this._stats = candidatePair;
-		
+
 		if (
 			candidatePair.localCandidateId && 
             candidatePair.localCandidateId !== this._selectedLocalCandidateId && 

src/ObservedInboundTrack.ts

@@ -82,6 +82,7 @@ export class ObservedInboundTrack<Kind extends MediaKind> extends EventEmitter	{
 		public readonly peerConnection: ObservedPeerConnection,
 	) {
 		super();
+		this.setMaxListeners(Infinity);
 	}
 
 	public get serviceId() {

src/ObservedOutboundTrack.ts

@@ -70,6 +70,7 @@ export class ObservedOutboundTrack<Kind extends MediaKind> extends EventEmitter
 		public readonly peerConnection: ObservedPeerConnection,
 	) {
 		super();
+		this.setMaxListeners(Infinity);
 	}
 
 	public get serviceId() {

src/ObservedPeerConnection.ts

@@ -85,6 +85,7 @@ export class ObservedPeerConnection extends EventEmitter {
 		public readonly client: ObservedClient,
 	) {
 		super();
+		this.setMaxListeners(Infinity);
 	}
 
 	public get serviceId() {

src/ObservedSfu.ts

@@ -32,6 +32,7 @@ export class ObservedSfu<AppData extends Record<string, unknown> = Record<string
 		public readonly appData: AppData,
 	) {
 		super();
+		this.setMaxListeners(Infinity);
 	}
 
 	public get serviceId() {

src/Observer.ts

@@ -71,6 +71,8 @@ export class Observer extends EventEmitter {
 		public readonly config: ObserverConfig,
 	) {
 		super();
+		this.setMaxListeners(Infinity);
+
 		logger.debug('Observer is created with config', this.config);
 		const onNewReport = (collectedReports: number) => {
 			if (!this.config.maxReports || this._closed) return;