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
index 6ed1f7ba..4f42572b 100644
--- 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