chore: change high performance EventEmitter

package.json

@@ -164,8 +164,8 @@
     ]
   },
   "dependencies": {
-    "events": "^3.3.0",
     "mqtt-packet": "^8.1.2",
-    "react-native-tcp-socket": "^6.0.6"
+    "react-native-tcp-socket": "^6.0.6",
+    "tseep": "^1.1.1"
   }
 }

src/index.ts

@@ -2,7 +2,7 @@ import type { Buffer } from 'buffer';
 import type { Packet, Parser } from 'mqtt-packet';
 import net from 'react-native-tcp-socket';
 import mqtt from 'mqtt-packet';
-import { EventEmitter } from 'events';
+import { EventEmitter } from 'tseep';
 
 export type Callback = (err?: Error | undefined) => any;
 
@@ -20,12 +20,18 @@ export class Client extends EventEmitter {
       this.emit('data', packet);
       this.emit(packet.cmd, packet);
     });
-    this.parser.on('error', this.emit.bind(this, 'error'));
+    this.parser.on('error', (err) => {
+      this.emit('error', err);
+    });
     this.socket.on('data', (data) => {
       this.parser.parse(data! as Buffer);
     });
-    this.socket.on('error', this.emit.bind(this, 'error'));
-    this.socket.on('close', this.emit.bind(this, 'close'));
+    this.socket.on('error', (err) => {
+      this.emit('error', err);
+    });
+    this.socket.on('close', () => {
+      this.emit('close');
+    });
   }
 
   setKeepAlive(keepalive: number) {

src/simple-mq.ts

@@ -9,7 +9,7 @@ import type {
   IUnsubscribePacket,
 } from 'mqtt-packet';
 import type { Buffer } from 'buffer';
-import { EventEmitter } from 'events';
+import { EventEmitter } from 'tseep';
 import { Server, Client } from './';
 
 const TOPIC_PART_LIMIT = 16;
@@ -77,9 +77,15 @@ export class SimpleMQBroker extends EventEmitter {
     this.keepalive = options.keepalive ?? 60;
     this.clients = {};
     this.server.on('connection', this.handleClient.bind(this));
-    this.server.on('error', this.emit.bind(this, 'error'));
-    this.server.on('close', this.emit.bind(this, 'close'));
-    this.server.on('listening', this.emit.bind(this, 'listening'));
+    this.server.on('error', (err) => {
+      this.emit('error', err);
+    });
+    this.server.on('close', () => {
+      this.emit('close');
+    });
+    this.server.on('listening', () => {
+      this.emit('listening');
+    });
     this.sessions = {};
     this.nextId = 1000;
   }

yarn.lock

@@ -9706,6 +9706,11 @@ ts-node@^10.8.1:
     v8-compile-cache-lib "^3.0.1"
     yn "3.1.1"
 
+tseep@^1.1.1:
+  version "1.1.1"
+  resolved "https://registry.yarnpkg.com/tseep/-/tseep-1.1.1.tgz#76d333d4a354cbfc627e957e49903cc53f46e17e"
+  integrity sha512-w2MjaqNWGDeliT5/W+/lhhnR0URiVwXXsXbkAZjQVywrOpdKhQAOL1ycyHfNOV1QBjouC7FawNmJePet1sGesw==
+
 tslib@^1.8.1:
   version "1.14.1"
   resolved "https://registry.npmjs.org/tslib/-/tslib-1.14.1.tgz"