diff options
Diffstat (limited to 'test/com')
| -rw-r--r-- | test/com/github/ivarref/yoltq/virtual_test.clj | 11 |
1 files changed, 10 insertions, 1 deletions
diff --git a/test/com/github/ivarref/yoltq/virtual_test.clj b/test/com/github/ivarref/yoltq/virtual_test.clj index 3c7c5b4..5e5fc92 100644 --- a/test/com/github/ivarref/yoltq/virtual_test.clj +++ b/test/com/github/ivarref/yoltq/virtual_test.clj @@ -20,7 +20,7 @@ (dq/init! {:conn conn}) (dq/add-consumer! :q identity) @(d/transact conn [(dq/put :q {:work 123})]) - (is (= {:work 123} (:retval (vq/run-queue-once! :q :init)))))) + (is (= {:work 123} (vq/consume! :q))))) (deftest happy-case-tx-report-q @@ -274,3 +274,12 @@ (binding [timbre/*context* {:x-request-id "123"}] @(d/transact conn [(dq/put :q nil)])) (is (= "123" (vq/consume-expect! :q :done))))) + + +(deftest consume-twice + (let [conn (u/empty-conn) + cnt (atom 0)] + (yq/init! {:conn conn}) + (yq/add-consumer! :q (fn [_] (swap! cnt inc))) + @(d/transact conn [(dq/put :q nil)]) + (is (= 2 (vq/consume-twice! :q))))) |