diff options
Diffstat (limited to 'stdlib/source/test/lux/control/concurrency/frp.lux')
| -rw-r--r-- | stdlib/source/test/lux/control/concurrency/frp.lux | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/stdlib/source/test/lux/control/concurrency/frp.lux b/stdlib/source/test/lux/control/concurrency/frp.lux index 174c8adc7..ad508df7b 100644 --- a/stdlib/source/test/lux/control/concurrency/frp.lux +++ b/stdlib/source/test/lux/control/concurrency/frp.lux @@ -59,7 +59,7 @@ (in #.End) (#.Some [head tail]) - (\ ! map (|>> (#.Item head)) + (\ ! each (|>> (#.Item head)) (take_amount (-- amount_of_polls) [channel sink])))))) (def: .public test @@ -152,12 +152,12 @@ (do ! [_ (!signal [])] (in #.None))))) - (/.sequential 0 (list\compose inputs inputs)))) + (/.sequential 0 (list\composite inputs inputs)))) _ ?signal listened (|> sink atom.read! async.future - (\ ! map row.list))] + (\ ! each row.list))] (_.cover' [/.Subscriber /.subscribe!] (list\= inputs listened)))) (in (do async.monad @@ -189,8 +189,8 @@ (list\= (list distint/0 distint/1 distint/2) actual)))) (do ! - [polling_delay (\ ! map (|>> (n.% 10) ++) random.nat) - amount_of_polls (\ ! map (|>> (n.% 10) ++) random.nat)] + [polling_delay (\ ! each (|>> (n.% 10) ++) random.nat) + amount_of_polls (\ ! each (|>> (n.% 10) ++) random.nat)] ($_ _.and (in (do {! async.monad} [actual (..take_amount amount_of_polls (/.poll polling_delay (: (IO Nat) (io.io sample)))) |