Merge pull request #3132 from mpilquist/topic/topic-suite-flaky

Mark flaky tests
typelevel · Feb 8, 2023 · d2c2cba · d2c2cba
2 parents 834335b + 201fc8c
commit d2c2cba
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/core/shared/src/test/scala/fs2/StreamCombinatorsSuite.scala b/core/shared/src/test/scala/fs2/StreamCombinatorsSuite.scala
@@ -404,7 +404,7 @@ class StreamCombinatorsSuite extends Fs2Suite {
         .assertEmits(List(1, 3, 5, 7, 9))
     }
 
-    test("filters up to N items in parallel") {
+    test("filters up to N items in parallel".flaky) {
       val s = Stream.range(0, 100)
       val n = 5
 

diff --git a/core/shared/src/test/scala/fs2/concurrent/TopicSuite.scala b/core/shared/src/test/scala/fs2/concurrent/TopicSuite.scala
@@ -71,7 +71,8 @@ class TopicSuite extends Fs2Suite {
     }
   }
 
-  test("unregister subscribers under concurrent load") {
+  // https://github.com/typelevel/fs2/issues/3071
+  test("unregister subscribers under concurrent load".flaky) {
     Topic[IO, Int].flatMap { topic =>
       val count = 100
       val subs = 10