From b094cb92740aca8cf4536011aa5f3016ccac41e5 Mon Sep 17 00:00:00 2001 From: Derrick Hammer Date: Wed, 31 Aug 2022 19:38:54 -0400 Subject: [PATCH] *Fix arguments for streamingQuery --- src/index.ts | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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) {