fs2
fs2 copied to clipboard
typelevel
Compositional, streaming I/O library for Scala
fs2 version 3.10.2 this codes prints `Succeeded` ```scala Stream .eval(IO.canceled) .parEvalMap(2)(_ => IO.unit) .onFinalizeCase(c => IO.delay(println(c))) .compile.drain ``` while using `evalMap` instead, it is properly `Canceled`: ```scala Stream .eval(IO.canceled) .evalMap(_...
fs2 version 3.10.2 this code does not terminate: ```scala Stream.unit // number of elements is irrelevant, as long as there are any; does not reproduce on Stream.empty .covary[IO] .parEvalMap(2)(_ =>...
Because of `Translate` we may only `G ~> F`, not `F ~> G`. However `GetScope` and any operator that uses `GetScope` is subject to a soundness hole since: * `Scope`...
Code: ```scala import scala.concurrent.duration._ import cats.effect.{IO, Resource} import fs2.Stream import cats.effect.unsafe.implicits.global Stream.resource( Resource.make(IO.println("start"))(_ => IO.println("stop")) ) .flatMap(_ => Stream(1,2,3,4).covary[IO].metered(100.millis)) .take(2) .evalTap(IO.println) .groupWithin(2, 1.second) .evalTap(IO.println) .compile .drain .unsafeRunSync() ``` Result: ```...
`Pull.extendScopeTo` [here](https://scastie.scala-lang.org/vcAPQVhjRZCraHj2QsBpcQ) A safer variant could be: ```scala object Pull { ... def leaseScope[F[_]: MonadThrow]: Pull[F, Nothing, Resource[F, Unit]] = Pull.getScope[F].map(s => Resource.make(s.lease)(_.cancel.rethrow)) } ``` The code that can produce...
It seems that supplying a relative `java.nio.file.Path` to the watcher's `fs2.io.Watcher#watch` method causes an NPE: ```scala import fs2.io.Watcher import fs2.io.file.{Files, Path} import cats.effect.* import cats.effect.unsafe.implicits.global @main def main = {...
Hi, I found an edge case which causes an exception to be swallowed while cancelling the stream. The following snippet prints `()` which was pretty unexpected for me. I would...
Implemented ProcessBuilder-based process spawning for Scala Native using posix_spawn, with support for stdin, stdout, and stderr piping. Integrated pidfd_open and fileDescriptorPoller to asynchronously and non-blockingly wait for process termination. Falls...
Fixes #3560 This PR revamps `fs2.io.net` in a number of significant ways: - Unifies support for IP and Unix sockets in to a single set of operations -- `connect` for...
