diff options
Diffstat (limited to '')
| -rw-r--r-- | stdlib/source/test/lux/control/concurrency/frp.lux | 42 |
1 files changed, 21 insertions, 21 deletions
diff --git a/stdlib/source/test/lux/control/concurrency/frp.lux b/stdlib/source/test/lux/control/concurrency/frp.lux index fcefb15ec..202bbc73c 100644 --- a/stdlib/source/test/lux/control/concurrency/frp.lux +++ b/stdlib/source/test/lux/control/concurrency/frp.lux @@ -14,7 +14,7 @@ ["[0]" io {"+" [IO io]}]] [data [collection - ["[0]" list ("[1]\[0]" mix monoid)] + ["[0]" list ("[1]#[0]" mix monoid)] ["[0]" row {"+" [Row]}]]] [math ["[0]" random] @@ -23,7 +23,7 @@ [\\library ["[0]" / [// - ["[0]" async {"+" [Async]} ("[1]\[0]" monad)] + ["[0]" async {"+" [Async]} ("[1]#[0]" monad)] ["[0]" atom {"+" [Atom atom]}]]]]) (def: injection @@ -50,7 +50,7 @@ (All (_ a) (-> Nat [(/.Channel a) (/.Sink a)] (Async (List a)))) (case amount_of_polls 0 (do async.monad - [_ (async.future (\ sink close))] + [_ (async.future (# sink close))] (in {.#End})) _ (do [! async.monad] [event channel] @@ -59,13 +59,13 @@ (in {.#End}) {.#Some [head tail]} - (\ ! each (|>> {.#Item head}) + (# ! each (|>> {.#Item head}) (take_amount (-- amount_of_polls) [channel sink])))))) (def: .public test Test (<| (_.covering /._) - (let [(^open "list\[0]") (list.equivalence n.equivalence)] + (let [(^open "list#[0]") (list.equivalence n.equivalence)] (do [! random.monad] [inputs (random.list 5 random.nat) sample random.nat @@ -87,8 +87,8 @@ (case (io.run! (do (try.with io.monad) [.let [[channel sink] (/.channel [])] - _ (\ sink feed sample) - _ (\ sink close)] + _ (# sink feed sample) + _ (# sink close)] (in channel))) {try.#Success channel} (io.run! @@ -107,8 +107,8 @@ (case (io.run! (do (try.with io.monad) [.let [[channel sink] (/.channel [])] - _ (\ sink close)] - (\ sink feed sample))) + _ (# sink close)] + (# sink feed sample))) {try.#Success _} false @@ -120,14 +120,14 @@ /.of_async /.list)] (_.cover' [/.of_async /.list] - (list\= (list sample) + (list#= (list sample) output)))) (in (do async.monad [output (|> inputs (/.sequential 0) /.list)] (_.cover' [/.sequential] - (list\= inputs + (list#= inputs output)))) (in (do async.monad [output (|> inputs @@ -135,7 +135,7 @@ (/.only n.even?) /.list)] (_.cover' [/.only] - (list\= (list.only n.even? inputs) + (list#= (list.only n.even? inputs) output)))) (in (do [! async.monad] [.let [[?signal !signal] (: [(async.Async Any) (async.Resolver Any)] @@ -152,21 +152,21 @@ (do ! [_ (!signal [])] (in {.#None}))))) - (/.sequential 0 (list\composite inputs inputs)))) + (/.sequential 0 (list#composite inputs inputs)))) _ ?signal listened (|> sink atom.read! async.future - (\ ! each row.list))] + (# ! each row.list))] (_.cover' [/.Subscriber /.subscribe!] - (list\= inputs listened)))) + (list#= inputs listened)))) (in (do async.monad [actual (/.mix (function (_ input total) (async.resolved (n.+ input total))) 0 (/.sequential 0 inputs))] (_.cover' [/.mix] - (n.= (list\mix n.+ 0 inputs) + (n.= (list#mix n.+ 0 inputs) actual)))) (in (do async.monad [actual (|> inputs @@ -176,7 +176,7 @@ 0) /.list)] (_.cover' [/.mixes] - (list\= (list.mixes n.+ 0 inputs) + (list#= (list.mixes n.+ 0 inputs) actual)))) (in (do async.monad [actual (|> (list distint/0 distint/0 distint/0 @@ -186,11 +186,11 @@ (/.distinct n.equivalence) /.list)] (_.cover' [/.distinct] - (list\= (list distint/0 distint/1 distint/2) + (list#= (list distint/0 distint/1 distint/2) actual)))) (do ! - [polling_delay (\ ! each (|>> (n.% 10) ++) random.nat) - amount_of_polls (\ ! each (|>> (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)))) @@ -218,6 +218,6 @@ /.list)] (_.cover' [/.iterations] (and (n.= max_iterations (list.size actual)) - (list\= (list.mixes n.+ sample (list.repeated (-- max_iterations) shift)) + (list#= (list.mixes n.+ sample (list.repeated (-- max_iterations) shift)) actual))))) ))))) |