diff options
Diffstat (limited to 'stdlib/source/library/lux/control/concurrency/stm.lux')
| -rw-r--r-- | stdlib/source/library/lux/control/concurrency/stm.lux | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/stdlib/source/library/lux/control/concurrency/stm.lux b/stdlib/source/library/lux/control/concurrency/stm.lux index 12e8b21e8..771b07b4a 100644 --- a/stdlib/source/library/lux/control/concurrency/stm.lux +++ b/stdlib/source/library/lux/control/concurrency/stm.lux @@ -221,10 +221,10 @@ [resolved? (resolve entry)] (if resolved? (atom.write! (product.right entry) pending_commits) - (recur |commits|&resolve))) + (again |commits|&resolve))) {.#Some [head tail]} - (recur tail))))))) + (again tail))))))) (def: (process_commit! commit) (All (_ a) (-> (Commit a) (IO Any))) @@ -247,10 +247,10 @@ (if was_first? (do ! [[async resolve] (atom.read! pending_commits)] - (async.upon! (function (recur [head [tail _resolve]]) + (async.upon! (function (again [head [tail _resolve]]) (do ! [_ (..process_commit! head)] - (async.upon! recur tail))) + (async.upon! again tail))) async)) (in []))) ))) |