diff options
Diffstat (limited to 'stdlib/source/test/lux/control/concurrency/frp.lux')
| -rw-r--r-- | stdlib/source/test/lux/control/concurrency/frp.lux | 26 |
1 files changed, 13 insertions, 13 deletions
diff --git a/stdlib/source/test/lux/control/concurrency/frp.lux b/stdlib/source/test/lux/control/concurrency/frp.lux index e7d418bf7..c9b19f1c7 100644 --- a/stdlib/source/test/lux/control/concurrency/frp.lux +++ b/stdlib/source/test/lux/control/concurrency/frp.lux @@ -16,14 +16,14 @@ [number ["n" nat]] [collection - ["." list ("#@." functor fold monoid)] + ["." list ("#\." fold monoid)] ["." row (#+ Row)]]] [math ["." random]]] {1 ["." / [// - ["." promise ("#@." monad)] + ["." promise ("#\." monad)] ["." atom (#+ Atom atom)]]]}) (def: injection @@ -49,7 +49,7 @@ (def: #export test Test (<| (_.covering /._) - (let [(^open "list@.") (list.equivalence n.equivalence)] + (let [(^open "list\.") (list.equivalence n.equivalence)] (do random.monad [inputs (random.list 5 random.nat) sample random.nat @@ -104,14 +104,14 @@ /.from-promise /.consume)] (_.claim [/.from-promise /.consume] - (list@= (list sample) + (list\= (list sample) output)))) (wrap (do promise.monad [output (|> inputs (/.sequential 0) /.consume)] (_.claim [/.sequential] - (list@= inputs + (list\= inputs output)))) (wrap (do promise.monad [output (|> inputs @@ -119,12 +119,12 @@ (/.filter n.even?) /.consume)] (_.claim [/.filter] - (list@= (list.filter n.even? inputs) + (list\= (list.filter n.even? inputs) output)))) (wrap (do {! promise.monad} [#let [sink (: (Atom (Row Nat)) (atom.atom row.empty)) - channel (/.sequential 0 (list@compose inputs inputs))] + channel (/.sequential 0 (list\compose inputs inputs))] _ (promise.future (/.subscribe (function (_ value) (do {! io.monad} [current (atom.read sink)] @@ -141,9 +141,9 @@ promise.future (:: ! map row.to-list))] (_.claim [/.Subscriber /.subscribe] - (and (list@= inputs + (and (list\= inputs output) - (list@= output + (list\= output listened))))) (wrap (do promise.monad [actual (/.fold (function (_ input total) @@ -151,7 +151,7 @@ 0 (/.sequential 0 inputs))] (_.claim [/.fold] - (n.= (list@fold n.+ 0 inputs) + (n.= (list\fold n.+ 0 inputs) actual)))) (wrap (do promise.monad [actual (|> inputs @@ -161,7 +161,7 @@ 0) /.consume)] (_.claim [/.folds] - (list@= (list.folds n.+ 0 inputs) + (list\= (list.folds n.+ 0 inputs) actual)))) (wrap (do promise.monad [actual (|> (list distint/0 distint/0 distint/0 @@ -171,7 +171,7 @@ (/.distinct n.equivalence) /.consume)] (_.claim [/.distinct] - (list@= (list distint/0 distint/1 distint/2) + (list\= (list distint/0 distint/1 distint/2) actual)))) (let [polling-delay 10 wiggle-room (n.* 5 polling-delay) @@ -207,6 +207,6 @@ /.consume)] (_.claim [/.iterate] (and (n.= max-iterations (list.size actual)) - (list@= (list.folds n.+ sample (list.repeat (dec max-iterations) shift)) + (list\= (list.folds n.+ sample (list.repeat (dec max-iterations) shift)) actual))))) ))))) |