fs2
fs2 copied to clipboard
Compositional, streaming I/O library for Scala
Updates [org.scalameta:scalafmt-core](https://github.com/scalameta/scalafmt) from 3.5.8 to 3.5.9. [GitHub Release Notes](https://github.com/scalameta/scalafmt/releases/tag/v3.5.9) - [Version Diff](https://github.com/scalameta/scalafmt/compare/v3.5.8...v3.5.9) I'll automatically update this PR to resolve conflicts as long as you don't change it yourself. If you'd...
Fix hanging when combining `Stream.eval(F.canceled)` and `interruptWhen`. I believe that the `.as(canceledError)` is safe as our `fa.attempt` was canceled which means that cancelation is unmasked in this scope and hence...
See https://github.com/typelevel/fs2/pull/2962 for a failing test. Removing the `interruptWhen` makes the test pass
The code below should just produce timeout, but it also prints `1` despite the fact that value was produced _after_ pause: ```scala Stream.eval(SignallingRef[IO].of(false)).flatMap { pause => Stream.sleep[IO](1.second).map(_ => 1).pauseWhen(pause).concurrently {...
Cats (https://github.com/typelevel/cats) recently added support (https://github.com/typelevel/cats/issues/1549) for cross-compiling to scala native. Scala Native support in fs2 would be be very helpful.
Opening this issue to track and see if anybody wants it. We didn't support it initially, because it requires JDK APIs not implemented in Scala.js.. https://github.com/typelevel/fs2/blob/a5566a6ff56fcba4f50896fdb32d54541f9c9ba5/io/shared/src/main/scala/fs2/io/file/Files.scala#L40-L41 However, Scala Native has...
It appears that resource finalizer is not being called correctly in order. In this simple example, almost all runs I did, the finalizer gets called before the last `.use` statement...
I'm experiencing a memory leak on the latest v3.2.7 when using an effect type that includes `WriterT`. I've put together a repository to reproduce the issue and to demonstrate that...