Maksym Ochenashko
Maksym Ochenashko
@tpolecat LGTM. This approach covers all my use cases. One little thing. I would like to have a bit more control over headers passed to Kernel: `val kernel = Kernel(req.headers.toList.map(h...
Hi @kaishh, thanks. Bifunctor solved my problem.
### The use-case The service consumes messages from the queue/socket (Kafka, ZMQ, etc) and broadcasts every message to N different pipelines. Perhaps I'm doing it wrong and I don't need...
@nikiforo thank you for the benchmark. The difference between `through` and `broadcast` is significant.
Unfortunately, I hit the issue again on the 3.x series. **cats-effect version:** 3.2.9 **fs2 version:** 3.2.1 Updated scastie: https://scastie.scala-lang.org/ilsZZTXWQpa07JbJrVCSaw Updated example: ```scala import cats.effect.{Resource, Ref, IO, IOApp, Outcome} import fs2.Stream...
@nikiforo works on 3.1.3, broken since 3.1.4
@nikiforo awesome, thanks! Let me know if I can help with an investigation
@nikiforo I didn't observe it yet (and hopefully will not). Thank you for your time!
I tried the `1.10.0-M1` release, and the sources of SBT and plugins were downloaded correctly. Thanks a lot!
@He-Pin you should use sbt `1.10.0-M1`. 1.9.7 doesn't download dependencies, unfortunately :(