3pp-mirror/penpot
1
0
Fork 0
mirror of https://github.com/penpot/penpot.git synced 2025-05-04 06:55:53 +02:00
Code Issues Projects Releases Packages Wiki Activity

✨ Minor improvements on batching channel impl.

Browse source
This commit is contained in:
Andrey Antukh 2021-05-14 12:37:44 +02:00 • committed by Alonso Torres
parent 610afc7702
commit ce19bcd364
1 changed files with 9 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
backend/src/app/util/async.clj
View file

@ -81,7 +81,11 @@
(recur (a/timeout max-batch-age) init))) (recur (a/timeout max-batch-age) init)))
(nil? val) (nil? val)
(a/close! out) (if (empty? buf)
(a/close! out)
(do
(a/offer! out [:timeout buf])
(a/close! out)))
(identical? port in) (identical? port in)
(let [buf (conj buf val)] (let [buf (conj buf val)]
@ -91,3 +95,7 @@
(recur (a/timeout max-batch-age) init)) (recur (a/timeout max-batch-age) init))
(recur tch buf)))))) (recur tch buf))))))
out)) out))
(defn thread-sleep
[ms]
(Thread/sleep ms))