diff options
| author | Eduardo Julian | 2017-01-28 23:53:11 -0400 |
|---|---|---|
| committer | Eduardo Julian | 2017-01-28 23:53:11 -0400 |
| commit | 97329ec45dd93dc1008d3778c6173fdfbfbd7ab8 (patch) | |
| tree | ed0788a96d029b7f6f4c921ae357b8af9bd73be2 /stdlib/test/test/lux/concurrency/frp.lux | |
| parent | 06246a89bb33b58a6e03183f59a2fea88179a861 (diff) | |
- Expanded the lux/concurrency/frp module.
- Some refactoring.
Diffstat (limited to '')
| -rw-r--r-- | stdlib/test/test/lux/concurrency/frp.lux | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/stdlib/test/test/lux/concurrency/frp.lux b/stdlib/test/test/lux/concurrency/frp.lux index ec128b119..80f15ad3d 100644 --- a/stdlib/test/test/lux/concurrency/frp.lux +++ b/stdlib/test/test/lux/concurrency/frp.lux @@ -71,7 +71,7 @@ (i.= 15 output))) (do Monad<Promise> - [elems (&;consume (&;no-dups number;Eq<Int> (List->Chan (list 0 0 0 1 2 2 3 3 3 3 4 4 4 5 5))))] + [elems (&;consume (&;distinct number;Eq<Int> (List->Chan (list 0 0 0 1 2 2 3 3 3 3 4 4 4 5 5))))] (assert "Can avoid immediate repetition in the channel." (case elems (^ (list 0 1 2 3 4 5)) @@ -81,7 +81,7 @@ false))) (do Monad<Promise> - [elems (&;consume (&;as-chan (:: promise;Monad<Promise> wrap 12345)))] + [elems (&;consume (&;once (:: promise;Monad<Promise> wrap 12345)))] (assert "Can convert a promise into a single-value channel." (case elems (^ (list 12345)) |