minor adjustments

olivermg · Jan 16, 2020 · 99cd00e · 99cd00e
1 parent 5422172
commit 99cd00e
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/src/cljc/broker/simple.cljc b/src/cljc/broker/simple.cljc
@@ -30,5 +30,7 @@
     (clj-brokee.consumer/subscribe c1 #{:t1} #(println "T1" %1 %2))
     (clj-brokee.consumer/subscribe c2 #{:t2 :t3} #(println "T2/3" %1 %2))
     (clj-brokee.producer/produce p1 :t1 {:foo "bar1"})
+    (Thread/sleep 100)
     (clj-brokee.producer/produce p1 :t2 {:foo "bar2"})
-    (clj-brokee.producer/produce p1 :t3 {:foo "bar3"}))
+    (Thread/sleep 100)
+    (clj-brokee.producer/produce p2 :t3 {:foo "bar3"}))
diff --git a/src/cljc/producer/simple.cljc b/src/cljc/producer/simple.cljc
@@ -10,4 +10,5 @@
   (produce [this topic message]
     (doseq [consumer (some-> broker :consumers deref)]
       (doseq [handle-fn (some-> consumer :subscriptions deref (get topic))]
-        (u/run-async handle-fn topic message)))))
+        (u/run-async handle-fn topic message)))
+    nil))