LumeWeb
/
libhyperproxy
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: LumeWeb:8e0edc4bcd789b9b731a7a4fd33d0216873aeab3
Branches Tags
LumeWeb:master
LumeWeb:develop
LumeWeb:v0.0.2-develop.4
LumeWeb:v0.0.2-develop.3
LumeWeb:v0.0.2-develop.2
LumeWeb:v0.0.2-develop.1
LumeWeb:v0.0.1
..
compare: LumeWeb:94e817f0450b9af819249f8ce91315c16fcb5f9e
Branches Tags
LumeWeb:develop
LumeWeb:master
LumeWeb:v0.0.2-develop.4
LumeWeb:v0.0.2-develop.3
LumeWeb:v0.0.2-develop.2
LumeWeb:v0.0.2-develop.1
LumeWeb:v0.0.1

2 Commits
8e0edc4bcd ... 94e817f045

Author SHA1 Message Date
Derrick Hammer 94e817f045
*Update dist 2023-04-08 20:56:45 -04:00
Derrick Hammer 92245a6c1c
*As a kernel-based protomux may be used, need to await on createChannel and addMessage 2023-04-08 20:56:26 -04:00
2 changed files with 4 additions and 4 deletions
Show Stats Expand all files Collapse all files

4
dist/peer.js vendored
View File

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

4
src/peer.ts
View File

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