diff options
Diffstat (limited to 'stdlib/source/test/lux/control/concurrency/frp.lux')
| -rw-r--r-- | stdlib/source/test/lux/control/concurrency/frp.lux | 15 |
1 files changed, 6 insertions, 9 deletions
diff --git a/stdlib/source/test/lux/control/concurrency/frp.lux b/stdlib/source/test/lux/control/concurrency/frp.lux index 8a279bac2..05fd6360c 100644 --- a/stdlib/source/test/lux/control/concurrency/frp.lux +++ b/stdlib/source/test/lux/control/concurrency/frp.lux @@ -19,10 +19,7 @@ [math ["[0]" random] [number - ["n" nat]]] - [meta - [type - ["[0]" variance]]]]] + ["n" nat]]]]] [\\library ["[0]" / (.only) [// @@ -44,7 +41,7 @@ (in (case [?left ?right] [{.#Some {.#Some [left _]}} {.#Some {.#Some [right _]}}] - (== (variance.read left) (variance.read right)) + (== left right) _ false)))))) @@ -62,7 +59,7 @@ (in {.#End}) {.#Some [head tail]} - (at ! each (|>> {.#Item (variance.read head)}) + (at ! each (|>> {.#Item head}) (take_amount (-- amount_of_polls) [channel sink])))))) (def .public test @@ -100,14 +97,14 @@ [?actual (async.value channel)] (in (case ?actual {.#Some {.#Some [actual _]}} - (n.= sample (variance.read actual)) + (n.= sample actual) _ false)))) {try.#Failure error} false)) - (_.coverage [/.channel_is_already_closed] + (_.coverage [/.already_closed] (case (io.run! (do (try.with io.monad) [.let [[channel sink] (is [(/.Channel Nat) (/.Sink Nat)] @@ -118,7 +115,7 @@ false {try.#Failure error} - (exception.match? /.channel_is_already_closed error))) + (exception.match? /.already_closed error))) (in (do async.monad [output (|> sample async.resolved |