diff --git a/src/query/simple.ts b/src/query/simple.ts
index 00c3250..06988d2 100644
--- a/src/query/simple.ts
+++ b/src/query/simple.ts
@@ -75,7 +75,7 @@ export default class SimpleRpcQuery extends RpcQueryBase {
 
     await socket.opened;
 
-    const rpc = setupStream(socket);
+    const rpc = await setupStream(socket);
 
     if (this._query.bypassCache) {
       delete this._query.bypassCache;