dist/peer.d.ts

@@ -14,7 +14,6 @@ export interface DataSocketOptions {
     onreceive?: OnReceive;
     onsend?: OnSend;
     onclose?: OnClose;
-    emulateWebsocket?: boolean;
 }
 export interface PeerOptions {
     peer: any;
@@ -32,7 +31,6 @@ export default class Peer {
     private _onreceive;
     private _onsend;
     private _onclose;
-    private _emulateWebsocket;
+    constructor({ proxy, peer, muxer, onopen, onreceive, onsend, onclose, }: PeerOptionsWithProxy & DataSocketOptions);
-    constructor({ proxy, peer, muxer, onopen, onreceive, onsend, onclose, emulateWebsocket, }: PeerOptionsWithProxy & DataSocketOptions);
     init(): Promise<void>;
 }

dist/peer.js

@@ -14,8 +14,7 @@ class Peer {
     _onreceive;
     _onsend;
     _onclose;
-    _emulateWebsocket;
+    constructor({ proxy, peer, muxer, onopen, onreceive, onsend, onclose, }) {
-    constructor({ proxy, peer, muxer, onopen, onreceive, onsend, onclose, emulateWebsocket = false, }) {
         this._proxy = proxy;
         this._peer = peer;
         this._muxer = muxer;
@@ -23,7 +22,6 @@ class Peer {
         this._onreceive = onreceive;
         this._onsend = onsend;
         this._onclose = onclose;
-        this._emulateWebsocket = emulateWebsocket;
     }
     async init() {
         const write = async (data, cb) => {
@@ -46,7 +44,6 @@ class Peer {
                     remotePort: self._peer.rawStream.remotePort,
                     remotePublicKey: self._peer.remotePublicKey,
                     write,
-                    emulateWebsocket: self._emulateWebsocket,
                 });
                 self._socket.on("end", () => channel.close());
                 let ret = await self._onopen?.(self._socket, m);

src/peer.ts

@@ -19,7 +19,6 @@ export interface DataSocketOptions {
   onreceive?: OnReceive;
   onsend?: OnSend;
   onclose?: OnClose;
-  emulateWebsocket?: boolean;
 }
 
 export interface PeerOptions {
@@ -40,7 +39,6 @@ export default class Peer {
   private _onreceive: OnReceive;
   private _onsend: OnSend;
   private _onclose: OnClose;
-  private _emulateWebsocket: boolean;
 
   constructor({
     proxy,
@@ -50,7 +48,6 @@ export default class Peer {
     onreceive,
     onsend,
     onclose,
-    emulateWebsocket = false,
   }: PeerOptionsWithProxy & DataSocketOptions) {
     this._proxy = proxy;
     this._peer = peer;
@@ -59,7 +56,6 @@ export default class Peer {
     this._onreceive = onreceive;
     this._onsend = onsend;
     this._onclose = onclose;
-    this._emulateWebsocket = emulateWebsocket;
   }
 
   async init() {
@@ -84,7 +80,6 @@ export default class Peer {
           remotePort: self._peer.rawStream.remotePort,
           remotePublicKey: self._peer.remotePublicKey,
           write,
-          emulateWebsocket: self._emulateWebsocket,
         });
         self._socket.on("end", () => channel.close());
         let ret = await self._onopen?.(self._socket, m);