feat(shuttle): Pipe connectionTimeout arg through EventStreamHubSubsc…

…riber Follow-up to farcasterxyz#2367. Missed piping through BaseHubSubscribers new `connectionTimeout` param through to EventStreamHubSubscriber.
tybook · Oct 25, 2024 · 0a46caf · 0a46caf
1 parent 913c0f6
commit 0a46caf
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/.changeset/itchy-feet-cough.md b/.changeset/itchy-feet-cough.md
@@ -0,0 +1,5 @@
+---
+"@farcaster/shuttle": patch
+---
+
+feat(shuttle): Pipe connectionTimeout arg through EventStreamHubSubscriber
diff --git a/packages/shuttle/src/shuttle/hubSubscriber.ts b/packages/shuttle/src/shuttle/hubSubscriber.ts
@@ -217,9 +217,10 @@ export class EventStreamHubSubscriber extends BaseHubSubscriber {
     eventTypes?: HubEventType[],
     totalShards?: number,
     shardIndex?: number,
+    connectionTimeout?: number,
     options?: EventStreamHubSubscriberOptions,
   ) {
-    super(label, hubClient.client, log, eventTypes, totalShards, shardIndex);
+    super(label, hubClient.client, log, eventTypes, totalShards, shardIndex, connectionTimeout);
     this.eventStream = eventStream;
     this.redis = redis;
     this.streamKey = `hub:${hubClient.host}:evt:msg:${shardKey}`;