dist/proxies/multiSocket.d.ts

@@ -10,7 +10,7 @@ export interface MultiSocketProxyOptions extends ProxyOptions {
     allowedPorts?: number[];
 }
 export default class MultiSocketProxy extends Proxy {
-    handlePeer({ peer, muxer, ...options }: DataSocketOptions & PeerOptions): Promise<void>;
+    handlePeer({ peer, muxer, ...options }: DataSocketOptions & PeerOptions): void;
     private socketClass;
     private _peers;
     private _nextPeer;

dist/proxies/multiSocket.js

@@ -55,16 +55,14 @@ const errorSocketEncoding = {
 };
 const nextSocketId = (0, util_js_1.idFactory)(1);
 class MultiSocketProxy extends proxy_js_1.default {
-    async handlePeer({ peer, muxer, ...options }) {
+    handlePeer({ peer, muxer, ...options }) {
-        const conn = new peer_js_1.default({
+        new peer_js_1.default({
             ...this.socketOptions,
             proxy: this,
             peer,
             muxer,
             ...options,
-        });
+        }).init();
-        await conn.init();
-        this.emit("peer", conn);
     }
     socketClass;
     _peers = new Map();

dist/proxy.d.ts

@@ -1,13 +1,11 @@
-/// <reference types="node" />
 import { DataSocketOptions, PeerOptions } from "./peer.js";
-import EventEmitter from "events";
 export interface ProxyOptions extends DataSocketOptions {
     swarm: any;
     protocol: string;
     listen?: boolean;
     autostart?: boolean;
 }
-export default abstract class Proxy extends EventEmitter {
+export default abstract class Proxy {
     protected _listen: any;
     protected _autostart: boolean;
     constructor({ swarm, protocol, onopen, onreceive, onsend, onclose, onchannel, listen, autostart, emulateWebsocket, }: ProxyOptions);

dist/proxy.js

@@ -4,12 +4,10 @@ var __importDefault = (this && this.__importDefault) || function (mod) {
 };
 Object.defineProperty(exports, "__esModule", { value: true });
 const protomux_1 = __importDefault(require("protomux"));
-const events_1 = __importDefault(require("events"));
+class Proxy {
-class Proxy extends events_1.default {
     _listen;
     _autostart;
     constructor({ swarm, protocol, onopen, onreceive, onsend, onclose, onchannel, listen = false, autostart = false, emulateWebsocket = false, }) {
-        super();
         this._swarm = swarm;
         this._protocol = protocol;
         this._listen = listen;

src/proxies/multiSocket.ts

@@ -70,20 +70,14 @@ const errorSocketEncoding = {
 const nextSocketId = idFactory(1);
 
 export default class MultiSocketProxy extends Proxy {
-  async handlePeer({
+  handlePeer({ peer, muxer, ...options }: DataSocketOptions & PeerOptions) {
-    peer,
+    new Peer({
-    muxer,
-    ...options
-  }: DataSocketOptions & PeerOptions) {
-    const conn = new Peer({
       ...this.socketOptions,
       proxy: this,
       peer,
       muxer,
       ...options,
-    });
+    }).init();
-    await conn.init();
-    this.emit("peer", conn);
   }
   private socketClass: any;
   private _peers: Map<string, PeerEntity> = new Map<string, PeerEntity>();

src/proxy.ts

@@ -1,6 +1,5 @@
 import Protomux from "protomux";
 import { DataSocketOptions, PeerOptions } from "./peer.js";
-import EventEmitter from "events";
 
 export interface ProxyOptions extends DataSocketOptions {
   swarm: any;
@@ -9,7 +8,7 @@ export interface ProxyOptions extends DataSocketOptions {
   autostart?: boolean;
 }
 
-export default abstract class Proxy extends EventEmitter {
+export default abstract class Proxy {
   protected _listen: any;
   protected _autostart: boolean;
 
@@ -25,7 +24,6 @@ export default abstract class Proxy extends EventEmitter {
     autostart = false,
     emulateWebsocket = false,
   }: ProxyOptions) {
-    super();
     this._swarm = swarm;
     this._protocol = protocol;
     this._listen = listen;