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:039583d77e84600c7d50c3d94aa02f24f4c6d355
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

2 Commits
7386b6de05 ... 039583d77e

Author SHA1 Message Date
Derrick Hammer 039583d77e
*Update dist 2023-04-08 16:45:01 -04:00
Derrick Hammer a7e0fbd190
* Refactor `util.ts` to use `existing.ready` instead of `existing._channel.ready` and replace `existing.ready` with `rpc.ready`. 2023-04-08 16:43:56 -04:00
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._channel.ready; await existing.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 existing.ready; await rpc.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._channel.ready; await existing.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 existing.ready; await rpc.ready;
return rpc; return rpc;
} }