diff --git a/src/index.ts b/src/index.ts
index 5138c3b..968798e 100644
--- a/src/index.ts
+++ b/src/index.ts
@@ -171,8 +171,9 @@ async function handleStreamingQuery(aq: ActiveQuery) {
       relay as Buffer | string,
       query.method,
       query.module,
+      aq.sendUpdate,
       query.data,
-      { ...options, streamHandler: aq.sendUpdate }
+      { ...options }
     );
     resp = await rpcQuery.result;
   } catch (e: any) {