dist/peer.d.ts

@@ -9,7 +9,6 @@ export type OnData = (peer: Peer, data: any) => void;
 export type OnReceive = OnData;
 export type OnClose = OnData;
 export type OnSend = OnData;
-export type OnChannel = (peer: Peer, channel: any) => void;
 export type OnOpenBound = (socket: Socket, data: any) => {
     connect: boolean;
 } | Promise<{
@@ -19,13 +18,11 @@ export type OnDataBound = (data: any) => void;
 export type OnReceiveBound = OnDataBound;
 export type OnCloseBound = OnDataBound;
 export type OnSendBound = OnDataBound;
-export type OnChannelBound = (channel: any) => void;
 export interface DataSocketOptions {
     onopen?: OnOpen;
     onreceive?: OnReceive;
     onsend?: OnSend;
     onclose?: OnClose;
-    onchannel?: OnChannel;
     emulateWebsocket?: boolean;
 }
 export interface PeerOptions {
@@ -44,9 +41,8 @@ export default class Peer {
     private _onreceive;
     private _onsend;
     private _onclose;
-    private _onchannel;
     private _emulateWebsocket;
-    constructor({ proxy, peer, muxer, onopen, onreceive, onsend, onclose, onchannel, emulateWebsocket, }: PeerOptionsWithProxy & DataSocketOptions);
+    constructor({ proxy, peer, muxer, onopen, onreceive, onsend, onclose, emulateWebsocket, }: PeerOptionsWithProxy & DataSocketOptions);
     private _channel?;
     get channel(): any;
     init(): Promise<void>;

dist/peer.js

@@ -14,9 +14,8 @@ class Peer {
     _onreceive;
     _onsend;
     _onclose;
-    _onchannel;
     _emulateWebsocket;
-    constructor({ proxy, peer, muxer, onopen, onreceive, onsend, onclose, onchannel, emulateWebsocket = false, }) {
+    constructor({ proxy, peer, muxer, onopen, onreceive, onsend, onclose, emulateWebsocket = false, }) {
         this._proxy = proxy;
         this._peer = peer;
         this._muxer = muxer;
@@ -24,7 +23,6 @@ class Peer {
         this._onreceive = onreceive?.bind(undefined, this);
         this._onsend = onsend?.bind(undefined, this);
         this._onclose = onclose?.bind(undefined, this);
-        this._onchannel = onchannel?.bind(undefined, this);
         this._emulateWebsocket = emulateWebsocket;
     }
     _channel;
@@ -76,7 +74,6 @@ class Peer {
                 await self._onreceive?.(m);
             },
         });
-        await this._onchannel?.(this._channel);
         await this._channel.open();
     }
 }

dist/proxy.d.ts

@@ -9,7 +9,7 @@ export default class Proxy {
     private _listen;
     private _socketOptions;
     private _autostart;
-    constructor({ swarm, protocol, onopen, onreceive, onsend, onclose, onchannel, listen, autostart, emulateWebsocket, }: ProxyOptions);
+    constructor({ swarm, protocol, onopen, onreceive, onsend, onclose, listen, autostart, emulateWebsocket, }: ProxyOptions);
     private _swarm;
     get swarm(): any;
     private _protocol;

dist/proxy.js

@@ -9,7 +9,7 @@ class Proxy {
     _listen;
     _socketOptions;
     _autostart;
-    constructor({ swarm, protocol, onopen, onreceive, onsend, onclose, onchannel, listen = false, autostart = false, emulateWebsocket = false, }) {
+    constructor({ swarm, protocol, onopen, onreceive, onsend, onclose, listen = false, autostart = false, emulateWebsocket = false, }) {
         this._swarm = swarm;
         this._protocol = protocol;
         this._listen = listen;
@@ -19,7 +19,6 @@ class Proxy {
             onreceive,
             onsend,
             onclose,
-            onchannel,
             emulateWebsocket,
         };
         this.init();

src/peer.ts

@@ -14,7 +14,6 @@ export type OnData = (peer: Peer, data: any) => void;
 export type OnReceive = OnData;
 export type OnClose = OnData;
 export type OnSend = OnData;
-export type OnChannel = (peer: Peer, channel: any) => void;
 
 export type OnOpenBound = (
   socket: Socket,
@@ -29,14 +28,11 @@ export type OnReceiveBound = OnDataBound;
 export type OnCloseBound = OnDataBound;
 export type OnSendBound = OnDataBound;
 
-export type OnChannelBound = (channel: any) => void;
-
 export interface DataSocketOptions {
   onopen?: OnOpen;
   onreceive?: OnReceive;
   onsend?: OnSend;
   onclose?: OnClose;
-  onchannel?: OnChannel;
   emulateWebsocket?: boolean;
 }
 
@@ -58,7 +54,6 @@ export default class Peer {
   private _onreceive: OnReceiveBound;
   private _onsend: OnSendBound;
   private _onclose: OnCloseBound;
-  private _onchannel: OnChannelBound;
   private _emulateWebsocket: boolean;
 
   constructor({
@@ -69,7 +64,6 @@ export default class Peer {
     onreceive,
     onsend,
     onclose,
-    onchannel,
     emulateWebsocket = false,
   }: PeerOptionsWithProxy & DataSocketOptions) {
     this._proxy = proxy;
@@ -79,7 +73,6 @@ export default class Peer {
     this._onreceive = onreceive?.bind(undefined, this);
     this._onsend = onsend?.bind(undefined, this);
     this._onclose = onclose?.bind(undefined, this);
-    this._onchannel = onchannel?.bind(undefined, this);
     this._emulateWebsocket = emulateWebsocket;
   }
 
@@ -137,7 +130,6 @@ export default class Peer {
       },
     });
 
-    await this._onchannel?.(this._channel);
     await this._channel.open();
   }
 }

src/proxy.ts

@@ -20,7 +20,6 @@ export default class Proxy {
     onreceive,
     onsend,
     onclose,
-    onchannel,
     listen = false,
     autostart = false,
     emulateWebsocket = false,
@@ -34,7 +33,6 @@ export default class Proxy {
       onreceive,
       onsend,
       onclose,
-      onchannel,
       emulateWebsocket,
     };
     this.init();