diff options
| author | Eduardo Julian | 2020-10-31 20:26:37 -0400 |
|---|---|---|
| committer | Eduardo Julian | 2020-10-31 20:26:37 -0400 |
| commit | 69272f598d831e89da83bdc8c9290d5607dfb14d (patch) | |
| tree | 4915f241708344209d4c35ccdc8b8e57bab68e4c /stdlib/source/lux/control/concurrency/process.lux | |
| parent | eea741e9b4a47ae09832311d6d61f0bd6024f673 (diff) | |
Re-named the directory for my bookmarks to better reflect what they are.
Diffstat (limited to '')
| -rw-r--r-- | stdlib/source/lux/control/concurrency/process.lux | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/stdlib/source/lux/control/concurrency/process.lux b/stdlib/source/lux/control/concurrency/process.lux index 7a4c46856..5e1bf7c3c 100644 --- a/stdlib/source/lux/control/concurrency/process.lux +++ b/stdlib/source/lux/control/concurrency/process.lux @@ -146,7 +146,7 @@ (def: #export (run! _) (-> Any (IO Any)) - (do {@ io.monad} + (do {! io.monad} [processes (atom.read ..runner)] (case processes ## And... we're done! @@ -154,7 +154,7 @@ (wrap []) _ - (do @ + (do ! [#let [now (.nat ("lux io current-time")) [ready pending] (list.partition (function (_ process) (|> (get@ #creation process) @@ -163,8 +163,8 @@ processes)] swapped? (atom.compare-and-swap processes pending ..runner)] (if swapped? - (do @ - [_ (monad.map @ (get@ #action) ready)] + (do ! + [_ (monad.map ! (get@ #action) ready)] (run! [])) (error! (ex.construct ..cannot-continue-running-processes [])))) ))) |