From 110d21f731ec05bfc98b0652ae0a1408e8a1cd75 Mon Sep 17 00:00:00 2001 From: Idan Tavor Date: Thu, 5 Sep 2024 14:45:51 +0300 Subject: [PATCH] fix tests --- test/ketu/async/integration_test.clj | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/test/ketu/async/integration_test.clj b/test/ketu/async/integration_test.clj index df58b4d..99f294e 100644 --- a/test/ketu/async/integration_test.clj +++ b/test/ketu/async/integration_test.clj @@ -229,7 +229,7 @@ (doseq [^ConsumerRecord record records] (async/>!! result-chan (String. ^"[B" (.value record)))) records)) - (validate [_ _] + (valid? [_ _] true))} source (source/source consumer-chan clicks-consumer-opts) clicks-producer-opts {:name "clicks-producer" @@ -263,7 +263,7 @@ :ketu.source/consumer-decorator (reify ConsumerDecorator (poll! [_ _ _] nil) - (validate [_ _] + (valid? [_ _] false))}] (is (thrown-with-msg? Exception #"Consumer decorator validation failed" (source/source consumer-chan clicks-consumer-opts)))))))