packages/bun/src/utils/tcp.ts

@@ -91,8 +91,11 @@ export abstract class BaseTcpTransport extends EventEmitter implements ITelegram
 
     handleError(socket: unknown, error: Error): void {
         this.log.error('error: %s', error.stack)
+
+        if (this.listenerCount('error') > 0) {
             this.emit('error', error)
         }
+    }
 
     handleConnect(socket: Socket): void {
         this._socket = socket
@@ -109,7 +112,11 @@ export abstract class BaseTcpTransport extends EventEmitter implements ITelegram
                     this.emit('ready')
                 }
             })
-            .catch((err) => this.emit('error', err))
+            .catch((err) => {
+                if (this.listenerCount('error') > 0) {
+                    this.emit('error', err)
+                }
+            })
     }
 
     async send(bytes: Uint8Array): Promise<void> {

packages/deno/src/utils/tcp.ts

@@ -87,8 +87,11 @@ export abstract class BaseTcpTransport extends EventEmitter implements ITelegram
 
     handleError(error: unknown): void {
         this.log.error('error: %s', error)
+
+        if (this.listenerCount('error') > 0) {
             this.emit('error', error)
         }
+    }
 
     async handleConnect(socket: Deno.TcpConn): Promise<void> {
         this._socket = socket

packages/node/src/utils/tcp.ts

@@ -84,8 +84,11 @@ export abstract class BaseTcpTransport extends EventEmitter implements ITelegram
 
     handleError(error: Error): void {
         this.log.error('error: %s', error.stack)
+
+        if (this.listenerCount('error') > 0) {
             this.emit('error', error)
         }
+    }
 
     handleConnect(): void {
         this.log.info('connected')