remove should-poll? from decorator context

AppsFlyer · Jul 25, 2024 · 0b23bc6 · 0b23bc6
1 parent f734328
commit 0b23bc6
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/src/ketu/async/source.clj b/src/ketu/async/source.clj
@@ -105,8 +105,7 @@
         consumer-close-timeout-ms (:ketu.source/consumer-close-timeout-ms opts)
         should-poll? (volatile! true)
         decorator-fn (some-> (:ketu.source/consumer-decorator opts)
-                             (partial {:ketu.source/consumer consumer
-                                       :ketu.source/should-poll? should-poll?}))
+                             (partial {:ketu.source/consumer consumer}))
 
         abort-pending-put (async/chan)
         done-putting (async/chan)