aboutsummaryrefslogtreecommitdiff
path: root/stdlib/source/lux/control/concurrency/process.lux
diff options
context:
space:
mode:
authorEduardo Julian2019-07-26 21:23:27 -0400
committerEduardo Julian2019-07-26 21:23:27 -0400
commita0889b2ee76c1ae7a9a5bbe2eec9f051b4f341e4 (patch)
tree08df3db7f8fffad6360a476d20db1d40b36c85cb /stdlib/source/lux/control/concurrency/process.lux
parent78fd01f7e6688448bbd710336d4d7b1c35ae058a (diff)
No more "n/"-prefixed functions.
Diffstat (limited to '')
-rw-r--r--stdlib/source/lux/control/concurrency/process.lux6
1 files changed, 4 insertions, 2 deletions
diff --git a/stdlib/source/lux/control/concurrency/process.lux b/stdlib/source/lux/control/concurrency/process.lux
index 7cb569ee9..d31edfb59 100644
--- a/stdlib/source/lux/control/concurrency/process.lux
+++ b/stdlib/source/lux/control/concurrency/process.lux
@@ -8,6 +8,8 @@
["ex" exception (#+ exception:)]
["." io (#+ IO io)]]
[data
+ [number
+ ["n" nat]]
[collection
["." list]]]]
[//
@@ -142,8 +144,8 @@
[#let [now (.nat ("lux io current-time"))
[ready pending] (list.partition (function (_ process)
(|> (get@ #creation process)
- (n/+ (get@ #delay process))
- (n/<= now)))
+ (n.+ (get@ #delay process))
+ (n.<= now)))
processes)]
swapped? (atom.compare-and-swap processes pending runner)]
(if swapped?