Skip to content

Commit 635e33b

Browse files
authored
Fix race condition
1 parent 641b5f1 commit 635e33b

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4729,7 +4729,7 @@ object Stream extends StreamLowPriority {
47294729
* scala> import cats.effect.IO
47304730
* scala> import cats.effect.unsafe.implicits.global
47314731
* scala> import scala.concurrent.duration._
4732-
* scala> val s = (Stream("elem") ++ Stream.sleep_[IO](2.seconds)).repeat.take(3)
4732+
* scala> val s = (Stream("elem") ++ Stream.sleep_[IO](1500.millis)).repeat.take(3)
47334733
* scala> s.pull
47344734
* | .timed { timedPull =>
47354735
* | def go(timedPull: Pull.Timed[IO, String]): Pull[IO, String, Unit] =

0 commit comments

Comments
 (0)