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

mpilquist · web-flow · commit d2c2cba4aa15 · 2023-02-08T08:37:42.000-05:00
Mark flaky tests
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

Original file line number	Diff line number	Diff line change
`@@ -404,7 +404,7 @@ class StreamCombinatorsSuite extends Fs2Suite {`
`404`	`404`	`.assertEmits(List(1, 3, 5, 7, 9))`
`405`	`405`	`}`
`406`	`406`
`407`		`- test("filters up to N items in parallel") {`
	`407`	`+ test("filters up to N items in parallel".flaky) {`
`408`	`408`	`val s = Stream.range(0, 100)`
`409`	`409`	`val n = 5`
`410`	`410`
Original file line number	Diff line number	Diff line change
`@@ -71,7 +71,8 @@ class TopicSuite extends Fs2Suite {`
`71`	`71`	`}`
`72`	`72`	`}`
`73`	`73`
`74`		`- test("unregister subscribers under concurrent load") {`
	`74`	`+ // https://github.com/typelevel/fs2/issues/3071`
	`75`	`+ test("unregister subscribers under concurrent load".flaky) {`
`75`	`76`	`Topic[IO, Int].flatMap { topic =>`
`76`	`77`	`val count = 100`
`77`	`78`	`val subs = 10`