I have a simple Scala application that uses parquet4s with fs2 to read a set of partitioned records (spread across directories, generated by a Spark job). When I run the app, it only returns a fractio...

I've been struggling with error accumulation with effects, and I was wondering what the idiomatic way of modeling this is using Cats Effect. Without involving effects, I would do something like this: ...

I tried to write a Kleisli.ap function. final case class Kleisli[F[_], -A, B](run: (A) ⇒ F[B]) extends Product with Serializable def ap[C, D, AA <: A](f: Kleisli[F, AA, C])(implicit F: Apply[F], e...

How may I add new elements to fs2.Stream dynamically? For example, I would like to read key pressed as stream. I have tried to build the stream using Stream.eval with a function that use foreverM insi...