*Fix arguments for streamingQuery

2022-08-31 19:38:54 -04:00 · 2022-08-31 19:38:54 -04:00 · b094cb9274
parent af08c1f01c
commit b094cb9274
1 changed files with 2 additions and 1 deletions
--- 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) {