fs2
fs2 copied to clipboard
typelevel
Compositional, streaming I/O library for Scala
Not sure where exactly but it would be nice to include these types of apps in docs and ensure they stay compiling as we evolve APIs. https://gist.github.com/djspiewak/b1bfa4f7fe30bdd0ead89f5286f9ad06
I came across a failing prop for `StreamMergeSuite` while trying to debug some platform-specific issues related to CE3. ``` ==> X fs2.StreamMergeSuite.merge - left/right failure - 2 - never-ending flatMap,...
It should cover when you'd use and how to use: - parEvalMap/Unordered - parJoin - concurrently - merge* There's the page on Queue/Topic/etc but there's not a great single page...
I've only seen this once but it should be easy to reproduce using the init seed. ``` 2020-06-30T13:24:01.2915898Z [info] - deflate |> inflate ~= id *** FAILED *** (15 milliseconds)...
Gzip compressed files produced with `fs2.compression.gzip` are not recognized by gzip 1.3.12. This is primarily an issue for users on CentOS 6 (CentOS 7 ships a newer version that handles...
fs2-core 2.3.0, Scala 2.13.1, Scala.js 0.6.23 Ran into a very weird issue: - If a signal is made with some Cartesian operator like `mapN` or `product`, and - a `.discrete`...
Brought up by @augustjune on Gitter today: ```scala @ def holdLater[F[_]: Concurrent, A](stream: Stream[F, A]): Stream[F, Signal[F, A]] = { def uncons1(stream: Stream[F, A]): Stream[F, (A, Stream[F, A])] = stream.pull.uncons1.flatMap...
Hi. The following piece of code shows that in version 1.0.5, when a pipe given to `observe` fails, a folded stream fails to comply with its guarantee of single emission....
It should be possible to implement a Parallel instance for Stream where the parallel applicative zips streams. We should get that :) I would like to give this a try...
See the example below: ```scala package example import java.util.concurrent.atomic.AtomicLong import cats.effect._ import cats.syntax.flatMap._ import cats.syntax.functor._ import fs2._ import scala.compat.Platform.ConcurrentModificationException import scala.concurrent.duration._ import scala.concurrent.blocking class MiniKafka { final val NO_CURRENT_THREAD =...
