This repository was archived by the owner on Jun 10, 2021. It is now read-only.
File tree Expand file tree Collapse file tree 3 files changed +5
-9
lines changed
src/test/scala/asyncstreams/monixTask Expand file tree Collapse file tree 3 files changed +5
-9
lines changed Original file line number Diff line number Diff line change 1- sbt.version = 0.13.15
1+ sbt.version = 0.13.16
Original file line number Diff line number Diff line change @@ -22,7 +22,7 @@ See more examples in tests.
2222
2323asyncstreams is tested to work with:
2424- standard scala futures
25- - monix tasks (WIP, there are some issues)
25+ - monix tasks
2626
2727asyncstreams is available via jitpack:
2828
Original file line number Diff line number Diff line change @@ -61,12 +61,10 @@ class AsyncStreamTests extends FunSuite with Matchers {
6161 wait(r.to[List ]) shouldBe List (0 , 1 , 2 )
6262 }
6363
64- /*
65- Fails with timeout
6664 test(" folding large stream should not crash" ) {
6765 val r = makeInfStream.takeWhile(_ < 1000000 )
68- wait(r.to[List], 30 .seconds) shouldBe (0 to 999999)
69- }*/
66+ wait(r.to[List ], 10 .seconds) shouldBe (0 to 999999 )
67+ }
7068
7169 test(" foreach" ) {
7270 val stream = makeInfStream.take(10 )
@@ -84,11 +82,9 @@ class AsyncStreamTests extends FunSuite with Matchers {
8482 buffer.to[List ] shouldBe 0 :: 1 :: 2 :: 3 :: 4 :: 5 :: 6 :: 7 :: 8 :: 9 :: Nil
8583 }
8684
87- /*
88- Fails with timeout
8985 test(" flatten" ) {
9086 val stream = Vector .range(0 , 1000000 ).grouped(10 ).to[Vector ].toAS[Task ]
9187 val flatStream = stream.flatten
9288 wait(flatStream.to[Vector ], 60 .seconds) shouldBe Vector .range(0 , 1000000 )
93- }*/
89+ }
9490}
You can’t perform that action at this time.
0 commit comments