dist/index.js

@@ -64,7 +64,8 @@ export default class ProtomuxRPC extends EventEmitter {
             encoding: response,
             onmessage: this._onresponse.bind(this),
         });
-        await this._channel.open(options?.handshake);
+        this._channel.open(options?.handshake);
+        await this._channel.ready;
     }
     _onopen(handshake) {
         this.emit("open", handshake);

src/index.ts

@@ -80,7 +80,9 @@ export default class ProtomuxRPC extends EventEmitter {
       onmessage: this._onresponse.bind(this),
     });
 
-    await this._channel.open(options?.handshake);
+    this._channel.open(options?.handshake);
+
+    await this._channel.ready;
   }
 
   _onopen(handshake: any) {