diff options
Diffstat (limited to 'stdlib/source/test/lux/control/concurrency/frp.lux')
| -rw-r--r-- | stdlib/source/test/lux/control/concurrency/frp.lux | 64 |
1 files changed, 32 insertions, 32 deletions
diff --git a/stdlib/source/test/lux/control/concurrency/frp.lux b/stdlib/source/test/lux/control/concurrency/frp.lux index c9b19f1c7..fd5e7be02 100644 --- a/stdlib/source/test/lux/control/concurrency/frp.lux +++ b/stdlib/source/test/lux/control/concurrency/frp.lux @@ -103,24 +103,24 @@ promise.resolved /.from-promise /.consume)] - (_.claim [/.from-promise /.consume] - (list\= (list sample) - output)))) + (_.cover' [/.from-promise /.consume] + (list\= (list sample) + output)))) (wrap (do promise.monad [output (|> inputs (/.sequential 0) /.consume)] - (_.claim [/.sequential] - (list\= inputs - output)))) + (_.cover' [/.sequential] + (list\= inputs + output)))) (wrap (do promise.monad [output (|> inputs (/.sequential 0) (/.filter n.even?) /.consume)] - (_.claim [/.filter] - (list\= (list.filter n.even? inputs) - output)))) + (_.cover' [/.filter] + (list\= (list.filter n.even? inputs) + output)))) (wrap (do {! promise.monad} [#let [sink (: (Atom (Row Nat)) (atom.atom row.empty)) @@ -140,19 +140,19 @@ atom.read promise.future (:: ! map row.to-list))] - (_.claim [/.Subscriber /.subscribe] - (and (list\= inputs - output) - (list\= output - listened))))) + (_.cover' [/.Subscriber /.subscribe] + (and (list\= inputs + output) + (list\= output + listened))))) (wrap (do promise.monad [actual (/.fold (function (_ input total) (promise.resolved (n.+ input total))) 0 (/.sequential 0 inputs))] - (_.claim [/.fold] - (n.= (list\fold n.+ 0 inputs) - actual)))) + (_.cover' [/.fold] + (n.= (list\fold n.+ 0 inputs) + actual)))) (wrap (do promise.monad [actual (|> inputs (/.sequential 0) @@ -160,9 +160,9 @@ (promise.resolved (n.+ input total))) 0) /.consume)] - (_.claim [/.folds] - (list\= (list.folds n.+ 0 inputs) - actual)))) + (_.cover' [/.folds] + (list\= (list.folds n.+ 0 inputs) + actual)))) (wrap (do promise.monad [actual (|> (list distint/0 distint/0 distint/0 distint/1 @@ -170,9 +170,9 @@ (/.sequential 0) (/.distinct n.equivalence) /.consume)] - (_.claim [/.distinct] - (list\= (list distint/0 distint/1 distint/2) - actual)))) + (_.cover' [/.distinct] + (list\= (list distint/0 distint/1 distint/2) + actual)))) (let [polling-delay 10 wiggle-room (n.* 5 polling-delay) amount-of-polls 5 @@ -185,16 +185,16 @@ _ (promise.schedule total-delay (io.io [])) _ (promise.future (:: sink close)) actual (/.consume channel)] - (_.claim [/.poll] - (and (list.every? (n.= sample) actual) - (n.>= amount-of-polls (list.size actual)))))) + (_.cover' [/.poll] + (and (list.every? (n.= sample) actual) + (n.>= amount-of-polls (list.size actual)))))) (wrap (do promise.monad [#let [[channel sink] (/.periodic polling-delay)] _ (promise.schedule total-delay (io.io [])) _ (promise.future (:: sink close)) actual (/.consume channel)] - (_.claim [/.periodic] - (n.>= amount-of-polls (list.size actual))))))) + (_.cover' [/.periodic] + (n.>= amount-of-polls (list.size actual))))))) (wrap (do promise.monad [#let [max-iterations 10] actual (|> [0 sample] @@ -205,8 +205,8 @@ current]) #.None)))) /.consume)] - (_.claim [/.iterate] - (and (n.= max-iterations (list.size actual)) - (list\= (list.folds n.+ sample (list.repeat (dec max-iterations) shift)) - actual))))) + (_.cover' [/.iterate] + (and (n.= max-iterations (list.size actual)) + (list\= (list.folds n.+ sample (list.repeat (dec max-iterations) shift)) + actual))))) ))))) |