LumeWeb
/
rpc-client
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: LumeWeb:7386b6de0550de0427ea0067eb457c5eb9159edf
Branches Tags
LumeWeb:master
LumeWeb:develop
LumeWeb:v0.0.2-develop.6
LumeWeb:v0.0.2-develop.5
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:05c9a7aea7a0e75d4a2a24cc251f59bb2aa4c1f0
Branches Tags
LumeWeb:develop
LumeWeb:master
LumeWeb:v0.0.2-develop.6
LumeWeb:v0.0.2-develop.5
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

No commits in common. "7386b6de0550de0427ea0067eb457c5eb9159edf" and "05c9a7aea7a0e75d4a2a24cc251f59bb2aa4c1f0" have entirely different histories.
7386b6de05 ... 05c9a7aea7

2 changed files with 2 additions and 2 deletions
Show Stats Expand all files Collapse all files

2
dist/util.js vendored
View File

@ -82,7 +82,7 @@ export function createHash(data) {
} }
export async function setupStream(stream) { export async function setupStream(stream) {
const existing = stream[RPC_PROTOCOL_SYMBOL]; const existing = stream[RPC_PROTOCOL_SYMBOL];
if (existing) { if (!existing) {
await existing._channel.ready; await existing._channel.ready;
return existing; return existing;
} }

2
src/util.ts
View File

@ -117,7 +117,7 @@ export function createHash(data: string): Buffer {
export async function setupStream(stream: any) { export async function setupStream(stream: any) {
const existing = stream[RPC_PROTOCOL_SYMBOL]; const existing = stream[RPC_PROTOCOL_SYMBOL];
if (existing) { if (!existing) {
await existing._channel.ready; await existing._channel.ready;
return existing; return existing;
} }