Merge pull request #193 from jgracin/issue-192

Fix issue #192 in topics-ready? - dereferencing deferred
FundingCircle · Sep 17, 2019 · ee35332 · ee35332
2 parents f3f5ea2 + 9cd9524
commit ee35332
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/src/jackdaw/admin.clj b/src/jackdaw/admin.clj
@@ -154,7 +154,7 @@
   [^AdminClient client topics]
   {:pre [(client? client)
          (sequential? topics)]}
-  (->> (describe-topics* client (map :topic-name topics))
+  (->> @(describe-topics* client (map :topic-name topics))
        (every? (fn [[topic-name {:keys [partition-info]}]]
                  (every? (fn [part-info]
                            (and (boolean (:leader part-info))

diff --git a/test/jackdaw/admin_test.clj b/test/jackdaw/admin_test.clj
@@ -108,6 +108,12 @@
       (is (set= [:cluster-id :controller :nodes]
                 (keys (admin/describe-cluster client)))))))
 
+(deftest test-topics-ready?
+  (with-mock-admin-client test-cluster
+    (fn [client]
+      (admin/create-topics! client (vals test-topics))
+      (is (admin/topics-ready? client (vals test-topics))))))
+
 (deftest test-partition-ids-of-topics
   (with-mock-admin-client test-cluster
     (fn [client]