aboutsummaryrefslogtreecommitdiff
path: root/stdlib/source/lux/concurrency/stm.lux
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--stdlib/source/lux/concurrency/stm.lux12
1 files changed, 6 insertions, 6 deletions
diff --git a/stdlib/source/lux/concurrency/stm.lux b/stdlib/source/lux/concurrency/stm.lux
index 69a36461a..a62a35677 100644
--- a/stdlib/source/lux/concurrency/stm.lux
+++ b/stdlib/source/lux/concurrency/stm.lux
@@ -76,8 +76,8 @@
(All [a] (-> (Var a) Tx (Maybe a)))
(|> tx
(list.find (function [[_var _original _current]]
- (is (:! (Var Unit) var)
- (:! (Var Unit) _var))))
+ (is? (:! (Var Unit) var)
+ (:! (Var Unit) _var))))
(:: maybe.Monad<Maybe> map (function [[_var _original _current]]
_current))
(:!!)
@@ -102,8 +102,8 @@
#.Nil
(#.Cons [_var _original _current] tx')
- (if (is (:! (Var Unit) var)
- (:! (Var Unit) _var))
+ (if (is? (:! (Var Unit) var)
+ (:! (Var Unit) _var))
(#.Cons {#var (:! (Var Unit) _var)
#original (:! Unit _original)
#current (:! Unit value)}
@@ -165,12 +165,12 @@
(def: (can-commit? tx)
(-> Tx Bool)
(list.every? (function [[_var _original _current]]
- (is _original (read!! _var)))
+ (is? _original (read!! _var)))
tx))
(def: (commit-var! [_var _original _current])
(-> (Ex [a] (Tx-Frame a)) Unit)
- (if (is _original _current)
+ (if (is? _original _current)
[]
(io.run (write! _current _var))))