diff options
Diffstat (limited to 'stdlib/source/library/lux/control/concurrency')
4 files changed, 9 insertions, 9 deletions
diff --git a/stdlib/source/library/lux/control/concurrency/actor.lux b/stdlib/source/library/lux/control/concurrency/actor.lux index 20ab00c06..0e248ff9b 100644 --- a/stdlib/source/library/lux/control/concurrency/actor.lux +++ b/stdlib/source/library/lux/control/concurrency/actor.lux @@ -18,7 +18,7 @@ [text ["%" format (#+ format)]] [collection - ["." list ("#\." monoid monad fold)]]] + ["." list ("#\." monoid monad)]]] ["." macro (#+ with_identifiers) ["." code] [syntax (#+ syntax:) diff --git a/stdlib/source/library/lux/control/concurrency/async.lux b/stdlib/source/library/lux/control/concurrency/async.lux index 58fbb4ea6..bdd852ffc 100644 --- a/stdlib/source/library/lux/control/concurrency/async.lux +++ b/stdlib/source/library/lux/control/concurrency/async.lux @@ -104,7 +104,7 @@ (def: &functor ..functor) - (def: (apply ff fa) + (def: (on fa ff) (let [[fb resolve] (..async [])] (exec (io.run! (..upon! (function (_ f) diff --git a/stdlib/source/library/lux/control/concurrency/frp.lux b/stdlib/source/library/lux/control/concurrency/frp.lux index cb3645138..1e447ef17 100644 --- a/stdlib/source/library/lux/control/concurrency/frp.lux +++ b/stdlib/source/library/lux/control/concurrency/frp.lux @@ -96,13 +96,13 @@ (def: &functor ..functor) - (def: (apply ff fa) + (def: (on fa ff) (do async.monad [item_f ff item_a fa] (case [item_f item_a] [(#.Some [head_f tail_f]) (#.Some [head_a tail_a])] - (in (#.Some [(head_f head_a) (apply tail_f tail_a)])) + (in (#.Some [(head_f head_a) (on tail_a tail_f)])) _ (in #.None))))) @@ -189,7 +189,7 @@ (#.Some [value ..empty])) async)) -(def: .public (aggregate f init channel) +(def: .public (mix f init channel) (All [a b] (-> (-> b a (Async a)) a (Channel b) (Async a))) @@ -202,9 +202,9 @@ (#.Some [head tail]) (do ! [init' (f head init)] - (aggregate f init' tail))))) + (mix f init' tail))))) -(def: .public (aggregates f init channel) +(def: .public (mixes f init channel) (All [a b] (-> (-> b a (Async a)) a (Channel b) (Channel a))) @@ -217,7 +217,7 @@ (#.Some [head tail]) (do ! [init' (f head init)] - (in (#.Some [init (aggregates f init' tail)])))))) + (in (#.Some [init (mixes f init' tail)])))))) (def: .public (poll milli_seconds action) (All [a] diff --git a/stdlib/source/library/lux/control/concurrency/stm.lux b/stdlib/source/library/lux/control/concurrency/stm.lux index a41d12aba..5e9759bdb 100644 --- a/stdlib/source/library/lux/control/concurrency/stm.lux +++ b/stdlib/source/library/lux/control/concurrency/stm.lux @@ -151,7 +151,7 @@ (def: &functor ..functor) - (def: (apply ff fa) + (def: (on fa ff) (function (_ tx) (let [[tx' f] (ff tx) [tx'' a] (fa tx')] |