Skip to content

Commit b160ab3

Browse files
committed
removing flaky flag, adding variance annotation
1 parent 8c4cdc2 commit b160ab3

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

core/shared/src/main/scala/fs2/Stream.scala

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,8 @@ import fs2.concurrent._
3737
import fs2.internal._
3838
import Pull.StreamPullOps
3939

40+
import scala.annotation.unchecked.uncheckedVariance
41+
4042
/** A stream producing output of type `O` and which may evaluate `F` effects.
4143
*
4244
* - '''Purely functional''' a value of type `Stream[F, O]` _describes_ an effectful computation.
@@ -1510,7 +1512,7 @@ final class Stream[+F[_], +O] private[fs2] (private[fs2] val underlying: Pull[F,
15101512
timeout: FiniteDuration
15111513
)(implicit F: Temporal[F2]): Stream[F2, Chunk[O]] = {
15121514

1513-
case class State(os: Chunk[O], supplyEnded: Boolean) {
1515+
case class State(@uncheckedVariance os: Chunk[O], supplyEnded: Boolean) {
15141516

15151517
val size: Long = os.size.toLong
15161518

core/shared/src/test/scala/fs2/StreamCombinatorsSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -745,7 +745,7 @@ class StreamCombinatorsSuite extends Fs2Suite {
745745
}
746746
}
747747

748-
test("accumulation and splitting".flaky) {
748+
test("accumulation and splitting") {
749749
val t = 200.millis
750750
val size = 5
751751
val sleep = Stream.sleep_[IO](2 * t)

0 commit comments

Comments
 (0)