dist/socket.d.ts

@@ -1,4 +1,6 @@
+/// <reference types="node" />
 import { Duplex, DuplexEvents, Callback } from "streamx";
+import { write } from "fs";
 type AddressFamily = "IPv6" | "IPv4";
 interface SocketOptions {
     allowHalfOpen?: boolean;
@@ -18,9 +20,6 @@ export default class Socket extends Duplex {
     writable: true;
     remotePublicKey: Uint8Array;
     private _emulateWebsocket;
-    addEventListener: typeof this.addListener;
-    removeEventListener: typeof this.removeListener;
-    send: typeof this.write;
     constructor({ allowHalfOpen, remoteAddress, remotePort, remotePublicKey, write, emulateWebsocket, }?: SocketOptions);
     private _connecting;
     get connecting(): boolean;
@@ -35,6 +34,11 @@ export default class Socket extends Duplex {
         port: any;
         family: AddressFamily;
     };
+    addEventListener: <TEvent extends "data" | "end" | "finish" | "pipe" | "readable" | "drain" | keyof import("streamx").StreamEvents | "piping">(event: TEvent, listener: TEvent extends "data" | "end" | "finish" | "pipe" | "readable" | "drain" | keyof import("streamx").StreamEvents | "piping" ? DuplexEvents<any, any>[TEvent] : (...args: any[]) => void) => this;
+    on: <TEvent extends "data" | "end" | "finish" | "pipe" | "readable" | "drain" | keyof import("streamx").StreamEvents | "piping">(event: TEvent, listener: TEvent extends "data" | "end" | "finish" | "pipe" | "readable" | "drain" | keyof import("streamx").StreamEvents | "piping" ? DuplexEvents<any, any>[TEvent] : (...args: any[]) => void) => this;
+    removeEventListener: <TEvent extends "data" | "end" | "finish" | "pipe" | "readable" | "drain" | keyof import("streamx").StreamEvents | "piping">(event: TEvent, listener: TEvent extends "data" | "end" | "finish" | "pipe" | "readable" | "drain" | keyof import("streamx").StreamEvents | "piping" ? DuplexEvents<any, any>[TEvent] : (...args: any[]) => void) => this;
+    off: <TEvent extends "data" | "end" | "finish" | "pipe" | "readable" | "drain" | keyof import("streamx").StreamEvents | "piping">(event: TEvent, listener: TEvent extends "data" | "end" | "finish" | "pipe" | "readable" | "drain" | keyof import("streamx").StreamEvents | "piping" ? DuplexEvents<any, any>[TEvent] : (...args: any[]) => void) => this;
+    send: typeof write;
     static isIP(input: string): number;
     static isIPv4(input: string): boolean;
     static isIPv6(input: string): boolean;

dist/socket.js

@@ -1,6 +1,7 @@
 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 const streamx_1 = require("streamx");
+const fs_1 = require("fs");
 const IPV4 = "IPv4";
 const IPV6 = "IPv6";
 class Socket extends streamx_1.Duplex {
@@ -26,9 +27,6 @@ class Socket extends streamx_1.Duplex {
             this.remoteFamily = type === 6 ? IPV6 : IPV4;
         }
         if (this._emulateWebsocket) {
-            this.addEventListener = this.addListener;
-            this.removeEventListener = this.removeListener;
-            this.send = this.write;
             this.addEventListener("data", (data) => 
             // @ts-ignore
             this.emit("message", new MessageEvent("data", { data })));
@@ -85,6 +83,11 @@ class Socket extends streamx_1.Duplex {
             family: this.remoteFamily,
         };
     }
+    addEventListener = this.addListener;
+    on = this.addListener;
+    removeEventListener = this.removeListener;
+    off = this.removeListener;
+    send = fs_1.write;
     static isIP(input) {
         if (Socket.isIPv4(input)) {
             return 4;

src/socket.ts

@@ -32,10 +32,6 @@ export default class Socket extends Duplex {
   public remotePublicKey: Uint8Array;
   private _emulateWebsocket: boolean;
 
-  declare addEventListener: typeof this.addListener;
-  declare removeEventListener: typeof this.removeListener;
-  declare send: typeof this.write;
-
   constructor({
     allowHalfOpen = false,
     remoteAddress,
@@ -61,9 +57,6 @@ export default class Socket extends Duplex {
     }
 
     if (this._emulateWebsocket) {
-      this.addEventListener = this.addListener;
-      this.removeEventListener = this.removeListener;
-      this.send = this.write;
       this.addEventListener("data", (data: any) =>
         // @ts-ignore
         this.emit("message", new MessageEvent("data", { data }))
@@ -126,6 +119,13 @@ export default class Socket extends Duplex {
     };
   }
 
+  addEventListener = this.addListener;
+  on = this.addListener;
+  removeEventListener = this.removeListener;
+  off = this.removeListener;
+
+  send = write;
+
   static isIP(input: string): number {
     if (Socket.isIPv4(input)) {
       return 4;