fs2
fs2 copied to clipboard
typelevel
Compositional, streaming I/O library for Scala
## About this PR 📦 Updates [org.scala-native:sbt-scala-native](https://github.com/scala-native/scala-native) from `0.4.17` to `0.5.6` 📜 [GitHub Release Notes](https://github.com/scala-native/scala-native/releases/tag/v0.5.6) - [Version Diff](https://github.com/scala-native/scala-native/compare/v0.4.17...v0.5.6) ## Usage ✅ **Please merge!** I'll automatically update this PR to resolve...
![typelevel-steward[bot] avatar](https://avatars.githubusercontent.com/u/3731824?v=4 "typelevel-steward[bot] avatar"){kind=avatar}
This is a continuation of https://github.com/typelevel/fs2/pull/3512 ### Original description Updates `parEvalMap*`, `broadcastThrough` and `prefetch` to extend the resource scope past the channel/topic used to implement concurrency for these operators. In...
Steps to reproduce: - generate a compressed file ```sh echo foo > foo; echo bar > bar; gzip -c foo bar > foobar.gz ``` - run the following code ```scala...
fs2 version: 3.11.0 scala version: 3.3.4 [Scastie](https://scastie.scala-lang.org/eDo0xTsNQJmG5UTC88Xl8g) The following code snippet throws a `java.util.NoSuchElementException: None.get`, which means that the stream is hanging. I expect it to throw `java.lang.Exception: boom` instead....
## About this PR 📦 Updates [org.scala-lang:scala-library](https://github.com/scala/scala) from `2.12.20` to `2.12.21` 📜 [GitHub Release Notes](https://github.com/scala/scala/releases/tag/v2.12.21) - [Version Diff](https://github.com/scala/scala/compare/v2.12.20...v2.12.21) ## Usage ✅ **Please merge!** I'll automatically update this PR to resolve...
Even though the order of messages is non-deterministic for concurrent publishers, all subscribers should receive messages in the same order, as arbitrated by the Topic. PR with a failing test:...
Failing tests for #3642.
Whenever `Topic#publish1` returns `Right(())`, all subscribers should receive the event. However, this is not the case when `publish1` races with `close`. PR with a failing test: #3645