diff --git a/build.sbt b/build.sbt index 80175134..383e520a 100644 --- a/build.sbt +++ b/build.sbt @@ -53,10 +53,10 @@ lazy val root = project val zioVersion = "2.0.21" val catsVersion = "2.9.0" -val catsEffectVersion = "3.4.8" +val catsEffectVersion = "3.5.3" val catsMtlVersion = "1.3.0" val disciplineScalaTestVersion = "2.2.0" -val fs2Version = "3.6.1" +val fs2Version = "3.9.4" val scalaJavaTimeVersion = "2.5.0" lazy val zioInteropTracer = crossProject(JSPlatform, JVMPlatform) diff --git a/zio-interop-cats-tests/jvm/src/test/scala/zio/interop/fs2StreamSpec.scala b/zio-interop-cats-tests/jvm/src/test/scala/zio/interop/fs2StreamSpec.scala index 14835ba2..99870c38 100644 --- a/zio-interop-cats-tests/jvm/src/test/scala/zio/interop/fs2StreamSpec.scala +++ b/zio-interop-cats-tests/jvm/src/test/scala/zio/interop/fs2StreamSpec.scala @@ -14,7 +14,7 @@ object fs2StreamSpec extends ZIOSpecDefault { val exception: Throwable = new Exception("Failed") def fs2StreamFromChunk[A](chunk: Chunk[A]) = - fs2.Stream.chunk[Task, A](fs2.Chunk.indexedSeq(chunk)) + fs2.Stream.chunk[Task, A](fs2.Chunk.from(chunk)) def assertEqual[A](actual: fs2.Stream[Task, A], expected: fs2.Stream[Task, A]) = for { 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 0da1aa0d..64ded47a 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 @@ -25,7 +25,7 @@ class ZStreamSyntax[R, E, A](private val stream: ZStream[R, E, A]) extends AnyVa fs2.Stream.resource(Resource.scopedZIO[R, E, ZIO[R, Option[E], Chunk[A]]](stream.toPull)).flatMap { pull => fs2.Stream.repeatEval(pull.unsome).unNoneTerminate.flatMap { chunk => - fs2.Stream.chunk(fs2.Chunk.indexedSeq(chunk)) + fs2.Stream.chunk(fs2.Chunk.from(chunk)) } } }