[i/items] items & item-ps cancel after done

hyperfiddle · Aug 29, 2024 · 57a4371 · 57a4371
1 parent 4ec2e38
commit 57a4371
Showing 1 changed file with 35 additions and 0 deletions.
diff --git a/test/hyperfiddle/incseq/items_eager_impl_test.cljc b/test/hyperfiddle/incseq/items_eager_impl_test.cljc
@@ -507,6 +507,22 @@
         _                   (q ::none)
         _                   (t/is (= ::none (q)))]))
 
+(t/deftest cancel-after-done
+  (let [q                   (->mq)
+        _                   (q (assoc (d/empty-diff 1) :grow 1 :change {0 :foo})) ; what input will return on transfer
+        items               (spawn-ps q)
+        [_in-step _in-done] (q)
+        _                   (t/is (= :items-step (q)))
+        _diff               @items
+        _                   (items)
+        _                   (t/is (= :input-cancel (q)))
+        _                   (t/is (= :items-step (q)))
+        _                   (t/is (thrown? Cancelled @items))
+        _                   (t/is (= :items-done (q)))
+        _                   (items)
+        _                   (q ::none)
+        _                   (t/is (= ::none (q)))]))
+
 (t/deftest item-ps-double-cancellation-idle
   (let [q                   (->mq)
         _                   (q (assoc (d/empty-diff 1) :grow 1 :change {0 :foo})) ; what input will return on transfer
@@ -543,6 +559,25 @@
         _                   (q ::none)
         _                   (t/is (= ::none (q)))]))
 
+(t/deftest item-ps-cancel-after-done
+  (let [q                   (->mq)
+        _                   (q (assoc (d/empty-diff 1) :grow 1 :change {0 :foo})) ; what input will return on transfer
+        items               (spawn-ps q)
+        [_in-step _in-done] (q)
+        _                   (t/is (= :items-step (q)))
+        diff                @items
+        _                   (t/is (= (assoc (d/empty-diff 1) :grow 1) (assoc diff :change {})))
+        item0               ((-> diff :change (get 0)) #(q :item0-step) #(q :item0-done))
+        _                   (t/is (= :item0-step (q)))
+        _                   (t/is (= :foo @item0))
+        _                   (item0)
+        _                   (t/is (= :item0-step (q)))
+        _                   (t/is (thrown? Cancelled @item0))
+        _                   (t/is (= :item0-done (q)))
+        _                   (item0)
+        _                   (q ::none)
+        _                   (t/is (= ::none (q)))]))
+
 ;; missing tests
 ;; - double cancel before termination
 ;;   - dead-item-ps