File tree Expand file tree Collapse file tree 2 files changed +5
-6
lines changed
Expand file tree Collapse file tree 2 files changed +5
-6
lines changed Original file line number Diff line number Diff line change 4646(defn ^:no-doc run-state-machine-wrapped [state]
4747 (try (async-runtime/run-state-machine state)
4848 (catch Throwable ex
49- (d/error! (async-runtime/aget-object state async-runtime/USER-START-IDX) ex)
50- (throw ex))))
49+ (d/error! (async-runtime/aget-object state async-runtime/USER-START-IDX) ex))))
5150
5251(defn ^:no-doc take! [state blk d]
5352 (let [handler (fn [x]
Original file line number Diff line number Diff line change 115115 (testing " timeouts"
116116 (is (= ::timeout @(go-off (<!? (d/timeout! (d/deferred ) 10 ::timeout )))))
117117 (is (= ::timeout @(d/timeout! (go-off (<!? (d/deferred ))) 10 ::timeout )))
118- (is (thrown? TimeoutException @(go-off (<!? (d/timeout! (d/deferred ) 10 )))))
119- (is (thrown? TimeoutException @(d/timeout! (go-off (<!? (d/deferred ))) 10 ))))
118+ (is (thrown? TimeoutException @(go-off (<!? (d/timeout! (d/deferred ) 11 )))))
119+ (is (thrown? TimeoutException @(d/timeout! (go-off (<!? (d/deferred ))) 12 ))))
120120
121121 (testing " alt"
122- (is (= ::timeout @(go-off (<!? (d/alt (d/deferred ) (d/timeout! (d/deferred ) 10 ::timeout ))))))
123- (is (= ::timeout @(d/alt (go-off (<!? (d/deferred ))) (d/timeout! (d/deferred ) 10 ::timeout ))))
122+ (is (= ::timeout @(go-off (<!? (d/alt (d/deferred ) (d/timeout! (d/deferred ) 13 ::timeout ))))))
123+ (is (= ::timeout @(d/alt (go-off (<!? (d/deferred ))) (d/timeout! (d/deferred ) 14 ::timeout ))))
124124 (is (= 1 @(go-off (<!? (d/alt (d/deferred ) (d/success-deferred 1 ))))))
125125 (is (= 1 @(d/alt (go-off (<!? (d/deferred ))) (d/success-deferred 1 ))))))
126126
You can’t perform that action at this time.
0 commit comments