Fix #14: no call to downstream complete with padded partition when there's no incomplete partition
This commit is contained in:
parent
e327d1899b
commit
5025e583f2
1 changed files with 1 additions and 1 deletions
|
|
@ -330,7 +330,7 @@
|
||||||
(vreset! barrier n)
|
(vreset! barrier n)
|
||||||
(.clear dq)
|
(.clear dq)
|
||||||
acc)
|
acc)
|
||||||
acc))
|
(rf acc)))
|
||||||
([acc x]
|
([acc x]
|
||||||
(let [b (vswap! barrier dec)]
|
(let [b (vswap! barrier dec)]
|
||||||
(when (< b n) (.add dq (if (nil? x) dq x)))
|
(when (< b n) (.add dq (if (nil? x) dq x)))
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue