Skip to content

Commit a21cfcc

Browse files
committed
Updated ::timeout symbol in window functions
The window functions dropping-stream and sliding-stream were using the symbols :timeout on their try_put! calls, although it is not the source of any bug, it is good to go with ::timeout instead since that's what is used throughout the rest of the project.
1 parent ed77569 commit a21cfcc

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

src/manifold/stream.clj

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1127,11 +1127,11 @@
11271127
(connect-via
11281128
source
11291129
(fn [val]
1130-
(d/let-flow [put-result (try-put! sink val 0 :timeout)]
1130+
(d/let-flow [put-result (try-put! sink val 0 ::timeout)]
11311131
(case put-result
11321132
true true
11331133
false false
1134-
:timeout true)))
1134+
::timeout true)))
11351135
sink
11361136
{:upstream? true
11371137
:downstream? true})
@@ -1156,12 +1156,12 @@
11561156
(fn [val]
11571157
(d/loop []
11581158
(d/chain
1159-
(try-put! sink val 0 :timeout)
1159+
(try-put! sink val 0 ::timeout)
11601160
(fn [put-result]
11611161
(case put-result
11621162
true true
11631163
false false
1164-
:timeout (d/chain (take! sink)
1164+
::timeout (d/chain (take! sink)
11651165
(fn [_] (d/recur))))))))
11661166
sink
11671167
{:upstream? true

0 commit comments

Comments
 (0)