dist/util.js

@@ -83,12 +83,12 @@ export function createHash(data) {
 export async function setupStream(stream) {
     const existing = stream[RPC_PROTOCOL_SYMBOL];
     if (existing) {
-        await existing.ready;
+        await existing._channel.ready;
         return existing;
     }
     const rpc = new RPC(stream);
     stream[RPC_PROTOCOL_SYMBOL] = rpc;
-    await rpc.ready;
+    await existing.ready;
     return rpc;
 }
 export async function maybeGetAsyncProperty(object) {

src/util.ts

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