diff options
Diffstat (limited to 'stdlib/source/lux/concurrency/frp.lux')
| -rw-r--r-- | stdlib/source/lux/concurrency/frp.lux | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/stdlib/source/lux/concurrency/frp.lux b/stdlib/source/lux/concurrency/frp.lux index 98de28d39..a8c017a90 100644 --- a/stdlib/source/lux/concurrency/frp.lux +++ b/stdlib/source/lux/concurrency/frp.lux @@ -30,14 +30,14 @@ (All [a] (-> (Channel a) a (IO Top))) (do io.Monad<IO> [listeners (atom.read channel)] - (monad.map @ (function [listener] (listener value)) listeners))) + (monad.map @ (function (_ listener) (listener value)) listeners))) ) ## [Values] (def: #export (filter predicate input) (All [a] (-> (-> a Bool) (Channel a) (Channel a))) (let [output (channel [])] - (exec (io.run (listen (function [value] + (exec (io.run (listen (function (_ value) (if (predicate value) (publish output value) (io []))) @@ -113,7 +113,7 @@ (def: (apply ff fa) (let [output (channel [])] - (exec (io.run (listen (function [f] + (exec (io.run (listen (function (_ f) (listen (|>> f (publish output)) fa)) ff)) |