Skip to content

Commit 578e24c

Browse files
committed
Use m.deferred/realized? everywhere on manifold code
1 parent 33cfd9e commit 578e24c

File tree

2 files changed

+7
-7
lines changed

2 files changed

+7
-7
lines changed

src/manifold/stream.clj

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -574,7 +574,7 @@
574574
(let [d (if (closed? stream)
575575
(d/success-deferred false)
576576
(put! stream (f)))]
577-
(if (realized? d)
577+
(if (d/realized? d)
578578
(when-not @d
579579
(do
580580
(@cancel)

test/manifold/stream_test.clj

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -307,19 +307,19 @@
307307

308308
(let [a (s/put! s 9)
309309
b (s/put! s 2)]
310-
(is (realized? a))
310+
(is (d/realized? a))
311311
(is (= true @a))
312-
(is (not (realized? b)))
312+
(is (not (d/realized? b)))
313313
(is (= 9 @(s/take! s)))
314-
(is (realized? b))
314+
(is (d/realized? b))
315315
(is (= true @b))
316316
(let [c (s/put! s 12)
317317
d (s/put! s 1)]
318-
(is (not (or (realized? c) (realized? d))))
318+
(is (not (or (d/realized? c) (d/realized? d))))
319319
(is (= 2 @(s/take! s)))
320-
(is (not (or (realized? c) (realized? d))))
320+
(is (not (or (d/realized? c) (d/realized? d))))
321321
(is (= 12 @(s/take! s)))
322-
(is (realized? d))
322+
(is (d/realized? d))
323323
(is (= true @d))
324324
(is (= 1 @(s/take! s)))))))
325325

0 commit comments

Comments
 (0)