* Refactor handlePeer function to use async/await and emit "peer" event, and make Proxy class extend EventEmitter.

src/proxies/multiSocket.ts

@@ -70,14 +70,20 @@ const errorSocketEncoding = {
 const nextSocketId = idFactory(1);
 
 export default class MultiSocketProxy extends Proxy {
-  handlePeer({ peer, muxer, ...options }: DataSocketOptions & PeerOptions) {
+  async handlePeer({
-    new Peer({
+    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,5 +1,6 @@
 import Protomux from "protomux";
 import { DataSocketOptions, PeerOptions } from "./peer.js";
+import EventEmitter from "events";
 
 export interface ProxyOptions extends DataSocketOptions {
   swarm: any;
@@ -8,7 +9,7 @@ export interface ProxyOptions extends DataSocketOptions {
   autostart?: boolean;
 }
 
-export default abstract class Proxy {
+export default abstract class Proxy extends EventEmitter {
   protected _listen: any;
   protected _autostart: boolean;
 
@@ -24,6 +25,7 @@ export default abstract class Proxy {
     autostart = false,
     emulateWebsocket = false,
   }: ProxyOptions) {
+    super();
     this._swarm = swarm;
     this._protocol = protocol;
     this._listen = listen;