diff options
Diffstat (limited to 'stdlib/source/lux/concurrency/frp.lux')
| -rw-r--r-- | stdlib/source/lux/concurrency/frp.lux | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/stdlib/source/lux/concurrency/frp.lux b/stdlib/source/lux/concurrency/frp.lux index 6d18a73bb..a45d01485 100644 --- a/stdlib/source/lux/concurrency/frp.lux +++ b/stdlib/source/lux/concurrency/frp.lux @@ -106,7 +106,7 @@ (All [a] (-> (List (Chan a)) (Chan a))) (let [output (chan ($ +0))] (exec (do &;Monad<Promise> - [_ (mapM @ (lambda [input] (pipe' input output)) xss)] + [_ (mapM @ (function [input] (pipe' input output)) xss)] (exec (io;run (close output)) (wrap []))) output))) @@ -240,7 +240,7 @@ (def: #export (sliding-window max inputs) (All [a] (-> Nat (Chan a) (Chan (List a)))) (let [(^open) &;Monad<Promise>] - (folds (lambda [input window] + (folds (function [input window] (let [window' (L/append window (list input))] (wrap (if (n.<= max (list;size window')) window' @@ -286,7 +286,7 @@ (struct: #export _ (Functor Chan) (def: (map f xs) (:: &;Functor<Promise> map - (lambda [?x+xs] + (function [?x+xs] (case ?x+xs #;None #;None (#;Some [x xs']) (#;Some [(f x) (map f xs')]))) @@ -302,7 +302,7 @@ (def: (apply ff fa) (let [fb (chan ($ +1))] (exec (let [(^open) Functor<Chan>] - (map (lambda [f] (pipe (map f fa) fb)) + (map (function [f] (pipe (map f fa) fb)) ff)) fb)))) @@ -312,7 +312,7 @@ (def: (join mma) (let [output (chan ($ +0))] (exec (let [(^open) Functor<Chan>] - (map (lambda [ma] + (map (function [ma] (pipe ma output)) mma)) output)))) |