Improve typings for event emitters

lib/Consumer.d.ts

@@ -7,7 +7,17 @@ export declare type ConsumerOptions = {
     rtpParameters: RtpParameters;
     appData?: Record<string, unknown>;
 };
-export declare class Consumer extends EnhancedEventEmitter {
+export declare type ConsumerEvents = {
+    transportclose: [];
+    trackended: [];
+};
+export declare type ConsumerObserverEvents = {
+    close: [];
+    pause: [];
+    resume: [];
+    trackended: [];
+};
+export declare class Consumer extends EnhancedEventEmitter<ConsumerEvents> {
     private readonly _id;
     private readonly _localId;
     private readonly _producerId;
@@ -17,7 +27,9 @@ export declare class Consumer extends EnhancedEventEmitter {
     private readonly _rtpParameters;
     private _paused;
     private readonly _appData;
-    protected readonly _observer: EnhancedEventEmitter;
+    protected readonly _observer: EnhancedEventEmitter<ConsumerObserverEvents, ConsumerObserverEvents & {
+        [x: `@${string}`]: any[];
+    }>;
     /**
      * @emits transportclose
      * @emits trackended
@@ -87,7 +99,7 @@ export declare class Consumer extends EnhancedEventEmitter {
      * @emits resume
      * @emits trackended
      */
-    get observer(): EnhancedEventEmitter;
+    get observer(): EnhancedEventEmitter<ConsumerObserverEvents>;
     /**
      * Closes the Consumer.
      */

lib/DataConsumer.d.ts

@@ -8,14 +8,26 @@ export declare type DataConsumerOptions = {
     protocol?: string;
     appData?: Record<string, unknown>;
 };
-export declare class DataConsumer extends EnhancedEventEmitter {
+export declare type DataConsumerEvents = {
+    transportclose: [];
+    open: [];
+    error: [Error];
+    close: [];
+    message: [string | Blob | ArrayBuffer];
+};
+export declare type DataConsumerObserverEvents = {
+    close: [];
+};
+export declare class DataConsumer extends EnhancedEventEmitter<DataConsumerEvents> {
     private readonly _id;
     private readonly _dataProducerId;
     private readonly _dataChannel;
     private _closed;
     private readonly _sctpStreamParameters;
     private readonly _appData;
-    protected readonly _observer: EnhancedEventEmitter;
+    protected readonly _observer: EnhancedEventEmitter<DataConsumerObserverEvents, DataConsumerObserverEvents & {
+        [x: `@${string}`]: any[];
+    }>;
     /**
      * @emits transportclose
      * @emits open
@@ -80,7 +92,7 @@ export declare class DataConsumer extends EnhancedEventEmitter {
      *
      * @emits close
      */
-    get observer(): EnhancedEventEmitter;
+    get observer(): EnhancedEventEmitter<DataConsumerObserverEvents>;
     /**
      * Closes the DataConsumer.
      */

lib/DataProducer.d.ts

@@ -8,13 +8,25 @@ export declare type DataProducerOptions = {
     protocol?: string;
     appData?: Record<string, unknown>;
 };
-export declare class DataProducer extends EnhancedEventEmitter {
+export declare type DataProducerEvents = {
+    transportclose: [];
+    open: [];
+    error: [Error];
+    close: [];
+    bufferedamountlow: [];
+};
+export declare type DataProducerObserverEvents = {
+    close: [];
+};
+export declare class DataProducer extends EnhancedEventEmitter<DataProducerEvents> {
     private readonly _id;
     private readonly _dataChannel;
     private _closed;
     private readonly _sctpStreamParameters;
     private readonly _appData;
-    protected readonly _observer: EnhancedEventEmitter;
+    protected readonly _observer: EnhancedEventEmitter<DataProducerObserverEvents, DataProducerObserverEvents & {
+        [x: `@${string}`]: any[];
+    }>;
     /**
      * @emits transportclose
      * @emits open
@@ -78,7 +90,7 @@ export declare class DataProducer extends EnhancedEventEmitter {
      *
      * @emits close
      */
-    get observer(): EnhancedEventEmitter;
+    get observer(): EnhancedEventEmitter<DataProducerObserverEvents>;
     /**
      * Closes the DataProducer.
      */

lib/Device.d.ts

@@ -28,7 +28,13 @@ export declare class Device {
     private _recvRtpCapabilities?;
     private readonly _canProduceByKind;
     private _sctpCapabilities?;
-    protected readonly _observer: EnhancedEventEmitter;
+    protected readonly _observer: EnhancedEventEmitter<{
+        [x: string]: any[];
+    }, {
+        [x: string]: any[];
+    } & {
+        [x: `@${string}`]: any[];
+    }>;
     /**
      * Create a new Device to connect to mediasoup server.
      *

lib/Device.js

@@ -2,11 +2,7 @@
 /* global RTCRtpTransceiver */
 var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
     if (k2 === undefined) k2 = k;
-    var desc = Object.getOwnPropertyDescriptor(m, k);
-    if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
-      desc = { enumerable: true, get: function() { return m[k]; } };
-    }
-    Object.defineProperty(o, k2, desc);
+    Object.defineProperty(o, k2, { enumerable: true, get: function() { return m[k]; } });
 }) : (function(o, m, k, k2) {
     if (k2 === undefined) k2 = k;
     o[k2] = m[k];