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

Compare commits

base: LumeWeb:039583d77e84600c7d50c3d94aa02f24f4c6d355
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:7386b6de0550de0427ea0067eb457c5eb9159edf
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. "039583d77e84600c7d50c3d94aa02f24f4c6d355" and "7386b6de0550de0427ea0067eb457c5eb9159edf" have entirely different histories.
039583d77e ... 7386b6de05

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

4
dist/util.js vendored
View File

@ -83,12 +83,12 @@ 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.ready; await existing._channel.ready;
return existing; return existing;
} }
const rpc = new RPC(stream); const rpc = new RPC(stream);
stream[RPC_PROTOCOL_SYMBOL] = rpc; stream[RPC_PROTOCOL_SYMBOL] = rpc;
await rpc.ready; await existing.ready;
return rpc; return rpc;
} }
export async function maybeGetAsyncProperty(object) { export async function maybeGetAsyncProperty(object) {

4
src/util.ts
View File

@ -118,14 +118,14 @@ 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.ready; await existing._channel.ready;
return existing; return existing;
} }
const rpc = new RPC(stream); const rpc = new RPC(stream);
stream[RPC_PROTOCOL_SYMBOL] = rpc; stream[RPC_PROTOCOL_SYMBOL] = rpc;
await rpc.ready; await existing.ready;
return rpc; return rpc;
} }