fs2
fs2 copied to clipboard
typelevel
Compositional, streaming I/O library for Scala
When publish1 races with close, the publish1 result might report successful publishing, but subscribers don't receive the event.
When materialization of a Stream returned from `Topic#subscribe` or `subscribeAwait` is done concurrently with closing the Topic, the stream returned from the subscription is (sometimes) not terminated, which is a...
I have a grpc use case with a stream that go to the server let call it input and a stream that come from the server let call it out...
Sketch for now... idea is to hook this up to otel4s via `Meter[F].batchCallback` cc @iRevive
This issue revolves around onFinalize (which would probably translate to the bracket operation) not behaving like expected. During work on fs2-kafka library with the help of colleagues we discovered that...
key.pem and cert.pem files are read from files that are publicly available. io/shared/resources directory contains files that should be private (or better yet, env variables?)
Current `groupWithin()` has a feature which doesn't fit our requirements. An example scenario: * The stream is started, but no element is available for a long time, longer than the...
This issue has been minorly discussed in discord in the cats-effect channel, but I have recently concluded that the most fruitful avenue for exploration may be in fs2 rather than...
Saw on GHA build: ``` ==> X fs2.ParEvalMapSuite.cancels running computations when error raised - parEvalMapUnordered 30.002s java.util.concurrent.TimeoutException: test timed out after 30 seconds ```