diff --git a/dist/proxies/multiSocket.d.ts b/dist/proxies/multiSocket.d.ts
index f24f0d0..ea254d5 100644
--- a/dist/proxies/multiSocket.d.ts
+++ b/dist/proxies/multiSocket.d.ts
@@ -1,8 +1,9 @@
 /// <reference types="node" />
 import Proxy, { ProxyOptions } from "../proxy.js";
 import type { TcpSocketConnectOpts } from "net";
-import Peer, { DataSocketOptions, PeerOptions } from "../peer.js";
+import { DataSocketOptions, PeerOptions } from "../peer.js";
 import { PeerEntity } from "./multiSocket/types.js";
+import Peer from "./multiSocket/peer.js";
 export interface MultiSocketProxyOptions extends ProxyOptions {
     socketClass?: any;
     server: boolean;
diff --git a/dist/proxies/multiSocket.js b/dist/proxies/multiSocket.js
index 931fe04..2b9f9d5 100644
--- a/dist/proxies/multiSocket.js
+++ b/dist/proxies/multiSocket.js
@@ -10,6 +10,7 @@ const serialize_error_1 = require("serialize-error");
 const b4a_1 = __importDefault(require("b4a"));
 const util_js_1 = require("../util.js");
 const dummySocket_js_1 = __importDefault(require("./multiSocket/dummySocket.js"));
+const peer_js_1 = __importDefault(require("./multiSocket/peer.js"));
 const socketEncoding = {
     preencode(state, m) {
         compact_encoding_1.uint.preencode(state, m.id);
@@ -54,7 +55,15 @@ const errorSocketEncoding = {
 };
 const nextSocketId = (0, util_js_1.idFactory)(1);
 class MultiSocketProxy extends proxy_js_1.default {
-    handlePeer({ peer, muxer, ...options }) { }
+    handlePeer({ peer, muxer, ...options }) {
+        new peer_js_1.default({
+            ...this.socketOptions,
+            proxy: this,
+            peer,
+            muxer,
+            ...options,
+        });
+    }
     socketClass;
     _peers = new Map();
     _nextPeer = (0, util_js_1.roundRobinFactory)(this._peers);
@@ -62,9 +71,6 @@ class MultiSocketProxy extends proxy_js_1.default {
     _allowedPorts = [];
     constructor(options) {
         super(options);
-        this._socketOptions.onchannel = this.handleNewPeerChannel.bind(this);
-        this._socketOptions.onclose = this.handleClosePeer.bind(this);
-        this._socketOptions.onopen = this.handlePeer.bind(this);
         if (options.socketClass) {
             this.socketClass = options.socketClass;
         }