Compare commits
No commits in common. "baf0ac31e6962da9a97c8267b9df07bb16e7b8bf" and "c9cfb64c80e47f9a9b120f6376e9ef10fcf2a0c0" have entirely different histories.
baf0ac31e6
...
c9cfb64c80
|
@ -1,23 +1,14 @@
|
|||
import Proxy from "./proxy.js";
|
||||
import Socket from "./socket.js";
|
||||
export type OnOpen = (peer: Peer, socket: Socket, data: any) => {
|
||||
export type OnOpen = (socket: Socket, data: any) => {
|
||||
connect: boolean;
|
||||
} | Promise<{
|
||||
connect: boolean;
|
||||
}> | Promise<void> | void;
|
||||
export type OnData = (peer: Peer, data: any) => void;
|
||||
export type OnData = (data: any) => void;
|
||||
export type OnReceive = OnData;
|
||||
export type OnClose = OnData;
|
||||
export type OnSend = OnData;
|
||||
export type OnOpenBound = (socket: Socket, data: any) => {
|
||||
connect: boolean;
|
||||
} | Promise<{
|
||||
connect: boolean;
|
||||
}> | Promise<void> | void;
|
||||
export type OnDataBound = (data: any) => void;
|
||||
export type OnReceiveBound = OnDataBound;
|
||||
export type OnCloseBound = OnDataBound;
|
||||
export type OnSendBound = OnDataBound;
|
||||
export interface DataSocketOptions {
|
||||
onopen?: OnOpen;
|
||||
onreceive?: OnReceive;
|
||||
|
|
|
@ -20,10 +20,10 @@ class Peer {
|
|||
this._proxy = proxy;
|
||||
this._peer = peer;
|
||||
this._muxer = muxer;
|
||||
this._onopen = onopen?.bind(undefined, this);
|
||||
this._onreceive = onreceive?.bind(undefined, this);
|
||||
this._onsend = onsend?.bind(undefined, this);
|
||||
this._onclose = onclose?.bind(undefined, this);
|
||||
this._onopen = onopen?.bind(this);
|
||||
this._onreceive = onreceive?.bind(this);
|
||||
this._onsend = onsend?.bind(this);
|
||||
this._onclose = onclose?.bind(this);
|
||||
this._emulateWebsocket = emulateWebsocket;
|
||||
}
|
||||
async init() {
|
||||
|
|
32
src/peer.ts
32
src/peer.ts
|
@ -2,7 +2,6 @@ import Proxy from "./proxy.js";
|
|||
import Socket from "./socket.js";
|
||||
import { Buffer } from "buffer";
|
||||
export type OnOpen = (
|
||||
peer: Peer,
|
||||
socket: Socket,
|
||||
data: any
|
||||
) =>
|
||||
|
@ -10,24 +9,11 @@ export type OnOpen = (
|
|||
| Promise<{ connect: boolean }>
|
||||
| Promise<void>
|
||||
| void;
|
||||
export type OnData = (peer: Peer, data: any) => void;
|
||||
export type OnData = (data: any) => void;
|
||||
export type OnReceive = OnData;
|
||||
export type OnClose = OnData;
|
||||
export type OnSend = OnData;
|
||||
|
||||
export type OnOpenBound = (
|
||||
socket: Socket,
|
||||
data: any
|
||||
) =>
|
||||
| { connect: boolean }
|
||||
| Promise<{ connect: boolean }>
|
||||
| Promise<void>
|
||||
| void;
|
||||
export type OnDataBound = (data: any) => void;
|
||||
export type OnReceiveBound = OnDataBound;
|
||||
export type OnCloseBound = OnDataBound;
|
||||
export type OnSendBound = OnDataBound;
|
||||
|
||||
export interface DataSocketOptions {
|
||||
onopen?: OnOpen;
|
||||
onreceive?: OnReceive;
|
||||
|
@ -50,10 +36,10 @@ export default class Peer {
|
|||
private _peer: any;
|
||||
private _muxer: any;
|
||||
private _socket?: Socket;
|
||||
private _onopen: OnOpenBound;
|
||||
private _onreceive: OnReceiveBound;
|
||||
private _onsend: OnSendBound;
|
||||
private _onclose: OnCloseBound;
|
||||
private _onopen: OnOpen;
|
||||
private _onreceive: OnReceive;
|
||||
private _onsend: OnSend;
|
||||
private _onclose: OnClose;
|
||||
private _emulateWebsocket: boolean;
|
||||
|
||||
private _channel?: any;
|
||||
|
@ -71,10 +57,10 @@ export default class Peer {
|
|||
this._proxy = proxy;
|
||||
this._peer = peer;
|
||||
this._muxer = muxer;
|
||||
this._onopen = onopen?.bind(undefined, this);
|
||||
this._onreceive = onreceive?.bind(undefined, this);
|
||||
this._onsend = onsend?.bind(undefined, this);
|
||||
this._onclose = onclose?.bind(undefined, this);
|
||||
this._onopen = onopen?.bind(this);
|
||||
this._onreceive = onreceive?.bind(this);
|
||||
this._onsend = onsend?.bind(this);
|
||||
this._onclose = onclose?.bind(this);
|
||||
this._emulateWebsocket = emulateWebsocket;
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue