Johan Andrén

Results 347 comments of Johan Andrén

What would be the benefit over just triggering futures in `wireTap`? Do you have a more concrete use case you can describe? I'd expect that for all use cases which...

https://jenkins.akka.io:8498/job/akka-nightly-jdk8/7991/consoleText

I think a `Sink` is the analogue of a `Collector` in Java streams, so feeding an Akka stream into one feels fairly useful (and not anything we'd want to remove),...

One thing missing before we can do that is #31087

https://github.com/akka/akka/runs/6741586189?check_suite_focus=true#step:5:3187

I think we discussed it during the Scala 3 work and said the implicit extension wasn't a very important feature and that we could skip that for Scala 3 and...

Cross linking a bit to https://github.com/akka/akka/issues/24276 about chunking of StreamRef data which we closed with the motivation that we should over over to reliable delivery instead of extending StreamRefs with...

There is still nothing about representing faulty elements in-stream as a Try/Either like Konrad suggested, so let's keep it around.

https://github.com/akka/akka/runs/7103285935?check_suite_focus=true#step:5:1268

To clarify, the current `flatMapMerge` implementation (`akka.stream.impl.fusing.FlattenMerge`) doesn't even look at the supervision strategy. There may be good technical reasons for this, I'm not sure, but a PR exploring if...