aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--stdlib/source/lux/concurrency/session.lux20
1 files changed, 10 insertions, 10 deletions
diff --git a/stdlib/source/lux/concurrency/session.lux b/stdlib/source/lux/concurrency/session.lux
index ea0f3666f..ac9f984d9 100644
--- a/stdlib/source/lux/concurrency/session.lux
+++ b/stdlib/source/lux/concurrency/session.lux
@@ -84,8 +84,8 @@
(All [value mine yours]
(-> (Lazy [mine yours])
(Lazy [(Read value mine) (Write value yours)])))
- (let [channel (promise.promise #.None)]
- (lazy.freeze [(function (_ _)
+ (lazy.freeze (let [channel (promise.promise #.None)]
+ [(function (_ _)
(let [[mine yours] (lazy.thaw session)]
(do promise.Monad<Promise>
[value channel]
@@ -100,8 +100,8 @@
(All [value mine yours]
(-> (Lazy [mine yours])
(Lazy [(Write value mine) (Read value yours)])))
- (let [channel (promise.promise #.None)]
- (lazy.freeze [(function (_ value)
+ (lazy.freeze (let [channel (promise.promise #.None)]
+ [(function (_ value)
(let [[mine yours] (lazy.thaw session)]
(exec (io.run (promise.resolve value channel))
(promise.promise (#.Some mine)))))
@@ -142,9 +142,9 @@
(All [myL yourL myR yourR]
(-> (Lazy [myL yourL]) (Lazy [myR yourR])
(Lazy [(Fork myL myR) (Join yourL yourR)])))
- (let [channel (: (Promise Bit)
- (promise.promise #.None))]
- (lazy.freeze [(function (_ signal)
+ (lazy.freeze (let [channel (: (Promise Bit)
+ (promise.promise #.None))]
+ [(function (_ signal)
(let [[myL yourL] (lazy.thaw left)
[myR yourR] (lazy.thaw right)]
(case signal
@@ -169,9 +169,9 @@
(All [myL yourL myR yourR]
(-> (Lazy [myL yourL]) (Lazy [myR yourR])
(Lazy [(Join myL myR) (Fork yourL yourR)])))
- (let [channel (: (Promise Bit)
- (promise.promise #.None))]
- (lazy.freeze [(function (_ _)
+ (lazy.freeze (let [channel (: (Promise Bit)
+ (promise.promise #.None))]
+ [(function (_ _)
(let [[myL yourL] (lazy.thaw left)
[myR yourR] (lazy.thaw right)]
(do promise.Monad<Promise>