Skip to content

Commit

Permalink
Update Cats Effect and FS2 (#689)
Browse files Browse the repository at this point in the history
- Update Cats Effect to 3.5.3
- Update FS2 to 3.9.4 and use updated APIs
  • Loading branch information
calvinlfer authored Feb 19, 2024
1 parent 660c3b7 commit 79a853c
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 4 deletions.
4 changes: 2 additions & 2 deletions build.sbt
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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 {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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))
}
}
}
Expand Down

0 comments on commit 79a853c

Please sign in to comment.