Compare commits

..

No commits in common. "94e817f0450b9af819249f8ce91315c16fcb5f9e" and "8e0edc4bcd789b9b731a7a4fd33d0216873aeab3" have entirely different histories.

2 changed files with 4 additions and 4 deletions

4
dist/peer.js vendored
View File

@ -52,7 +52,7 @@ class Peer {
}, },
emulateWebsocket: self._emulateWebsocket, emulateWebsocket: self._emulateWebsocket,
}); });
this._channel = await this._muxer.createChannel({ this._channel = this._muxer.createChannel({
protocol: this._proxy.protocol, protocol: this._proxy.protocol,
async onopen(m) { async onopen(m) {
if (!m) { if (!m) {
@ -75,7 +75,7 @@ class Peer {
}, },
}); });
if (this._createDefaultMessage) { if (this._createDefaultMessage) {
pipe = await this._channel.addMessage({ pipe = this._channel.addMessage({
async onmessage(m) { async onmessage(m) {
if (m instanceof Uint8Array) { if (m instanceof Uint8Array) {
m = buffer_1.Buffer.from(m); m = buffer_1.Buffer.from(m);

View File

@ -115,7 +115,7 @@ export default class Peer {
emulateWebsocket: self._emulateWebsocket, emulateWebsocket: self._emulateWebsocket,
}); });
this._channel = await this._muxer.createChannel({ this._channel = this._muxer.createChannel({
protocol: this._proxy.protocol, protocol: this._proxy.protocol,
async onopen(m: any) { async onopen(m: any) {
if (!m) { if (!m) {
@ -142,7 +142,7 @@ export default class Peer {
}); });
if (this._createDefaultMessage) { if (this._createDefaultMessage) {
pipe = await this._channel.addMessage({ pipe = this._channel.addMessage({
async onmessage(m: any) { async onmessage(m: any) {
if (m instanceof Uint8Array) { if (m instanceof Uint8Array) {
m = Buffer.from(m); m = Buffer.from(m);