fs2
fs2 copied to clipboard
typelevel
Compositional, streaming I/O library for Scala
This is a **dispensable** performance tweak. The same workaround is already used in fs2, so it should be fine to reuse it once again. But I could be absolutely wrong...
``` ==> X fs2.StreamCombinatorsSuite.evalFilterNotAsync - filters up to N items in parallel 2.02s java.util.NoSuchElementException: null [1133](https://github.com/mpilquist/fs2/actions/runs/4124422453/jobs/7123653749#step:11:1134) at fs2.Stream$CompileOps.lastOrError$$anonfun$1$$anonfun$1(Stream.scala:4875) [1134](https://github.com/mpilquist/fs2/actions/runs/4124422453/jobs/7123653749#step:11:1135) at scala.Option.fold(Option.scala:263) [1135](https://github.com/mpilquist/fs2/actions/runs/4124422453/jobs/7123653749#step:11:1136) at fs2.Stream$CompileOps.lastOrError$$anonfun$1(Stream.scala:4875) [1136](https://github.com/mpilquist/fs2/actions/runs/4124422453/jobs/7123653749#step:11:1137) at flatMap @ fs2.Compiler$Target.flatMap(Compiler.scala:163) [1137](https://github.com/mpilquist/fs2/actions/runs/4124422453/jobs/7123653749#step:11:1138)...
... but maybe they can be :) see context in https://github.com/typelevel/fs2/pull/3112#pullrequestreview-1263803863. One solution I experimented with in https://github.com/typelevel/fs2/pull/3112#issuecomment-1399139450 was when compiling the background stream in concurrently, instead of giving it...
# Context The fact that `Stream[F, O]` can be easily got from `Pull[F, O, Unit]` is severely used in this example. `Stream`'s bracket API does not allow the release action...
Originally reported by @kamilkloch , I've done some minimisation. Reproduced in fs2 3.4.0, it seemed to work correctly on 3.0.2 (which I happened to have at hand). @Jasper-M points to...
``` ==> X fs2.concurrent.TopicSuite.unregister subscribers under concurrent load 0.035s munit.ComparisonFailException: /home/runner/work/fs2/fs2/core/shared/src/test/scala/fs2/concurrent/TopicSuite.scala:113 112: .map { result => 113: assertEquals(result.toMap.size, subs / 2) 114: assertEquals(result.toMap, expected) values are not the same =>...
Take a look at https://github.com/nikiforo/fs21107 The project can be run with `sbt "test:runMain ru.delimobil.FS2Example"` I expect the execution to continue inifinitely. However it ends with `Errored(java.lang.IllegalArgumentException: TheException)` in tens seconds....
I don't know if there's enough demand/need for this, but I had a use case where I needed something like `debounce` but that keeps all the elements of the stream,...
I encountered this in a cross built app and it worked for 2.12/2.13 Here is a [scastie](https://scastie.scala-lang.org/lQww5YvcSamxsZNnB8ot0A) repro from @ChristopherDavenport via Discord I attempted my own repro before I found...
