prevent early termination of stream (#535)

zio · Apr 27, 2022 · bfb51e6 · bfb51e6
1 parent 9117f44
commit bfb51e6
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/zio-interop-cats/shared/src/main/scala/zio/stream/interop/FS2StreamSyntax.scala b/zio-interop-cats/shared/src/main/scala/zio/stream/interop/FS2StreamSyntax.scala
@@ -54,7 +54,7 @@ final class FS2RIOStreamSyntax[R, A](private val stream: Stream[RIO[R, _], A]) {
               .resource
               .drain
               .toScopedZIO
-              .fork
+              .forkScoped
         } yield ZStream.fromQueue(queue).flattenTake
       }
       .flatten
@@ -74,7 +74,7 @@ final class FS2RIOStreamSyntax[R, A](private val stream: Stream[RIO[R, _], A]) {
             .resource
             .drain
             .toScopedZIO
-            .fork
+            .forkScoped
         } yield ZStream.fromQueue(queue).flattenTake
       }
       .flatten