Update src/ketu/async/source.clj

Co-authored-by: Yevgeni Tsodikov <[email protected]>

src/ketu/async/source.clj

@@ -113,7 +113,7 @@
         ->data (->data-fn opts)
         put! (fn [record] (put-or-abort-pending! out-chan (->data record) abort-pending-put))
 
-        maybe-execute-custom-command (if commands-chan
+        maybe-execute-custom-command (if (some? commands-chan)
                                        (fn [] (when-let [command (async/poll! commands-chan)]
                                                 (command {:ketu.source/consumer consumer})))
                                        (fn []))