fs2
fs2 copied to clipboard
typelevel
Compositional, streaming I/O library for Scala
Some pipes occasionally get ahead by 1 element when broadcasting an un-chunked stream through multiple pipes using `broadcastThrough`. A reproduction of the issue, using Scala 2.13.6 and fs2 3.1.1, can...
using fs2 `3.0.6` and `3.1.0`. Here's a [scatsie](https://scastie.scala-lang.org/6ToFVBZvQ3ainW9QIokpfw). All code pasted in this issue is also in the scatsie. We have as an example of subscriber to a topic subscribing...
@SystemFw kindly explained in https://github.com/http4s/http4s/pull/5206 why it's a bad idea to use `Compiler.Target` as a context bound in downstream libraries, in place of `Concurrent` or `Sync`. It seems worth documenting...
So you cannot get back to the root of this section - just odd behaviour. Reproduction: - Click Simple Examples - Click Concurrency Primitives Browser: Chrome on Windows.  Same...
https://github.com/typelevel/fs2/runs/2746360895?check_suite_focus=true#step:6:849 ``` ==> X fs2.StreamCombinatorsSuite.groupWithin - accumulation and splitting 0.491s munit.ComparisonFailException: /home/runner/work/fs2/fs2/core/shared/src/test/scala/fs2/StreamCombinatorsSuite.scala:852 850 851: .toList 851 852: .assertEquals(expected) 852 853: } 853 values are not the same 854 => Obtained...
Worth noting that if we wanted to replace fs2.text.lines with ``` /** Transforms a stream of `String` such that each emitted `String` is a line from the input. */ def...
There is a problem with Topic (and I suspect with Signal as well), probably due to how CPU intensive Set comparison is. One of my teams had problems where reasonably...
Supersedes #2289 and #2300. Just to summarize a bunch of GitHub issues and Gitter conversations around fs2/http4s: the main objective here is to arrive at a safe, network API which...
While the behavior described here seems weird to me, I may miss something obvious. Excuse me if this is the case. So I have two streams and each does a...
When a stream is interrupted, I expect based on [these docs](https://fs2.io/#/guide?id=appendix-a1-how-interruption-of-streams-works) that the interruption is final and can only be handled with `Stream.bracket` (or something built on `Stream.bracket`). So, I...
