akka-stream-contrib
akka-stream-contrib copied to clipboard
akka
Add-ons to Akka Stream
Is there going to be a standard for documenting what's available here, with usage examples, etc?
Hi. Could anyone review my PR https://github.com/akka/akka-stream-contrib/pull/121?
the [`switch`](http://reactivex.io/documentation/operators/switch.html) and `switchMap` operators, as described in Rx (and also implemented in Monix), are very useful. For anyone not familiar with it, `switch` operates over a stream of streams,...
Upgrading from Akka 2.4.x with Contrib 0.6 to Akka 2.5 with Contrib 0.8 a NPE is raised from the `.assertAllStagesStopped` utility. ``` java.lang.NullPointerException: null (PhasedFusingActorMaterializer.scala:483) akka.stream.impl.PhasedFusingActorMaterializer.materialize(PhasedFusingActorMaterializer.scala:483) akka.stream.impl.PhasedFusingActorMaterializer.materialize(PhasedFusingActorMaterializer.scala:424) akka.stream.impl.PhasedFusingActorMaterializer.materialize(PhasedFusingActorMaterializer.scala:415) akka.stream.scaladsl.RunnableGraph.run(Flow.scala:439) akka.stream.scaladsl.Source.runWith(Source.scala:83)...
[info] PulseSpecAutoFusingOff: [info] Pulse Stage [info] - should signal demand once every interval (957 milliseconds) [info] - should keep backpressure if there is no demand from downstream (565 milliseconds) [info]...
It's actually not that clear to me why this test has an `initialTimeout` (and why the source repeats '1', wouldn't it be a more reliable test with `Source(1 to 10)`...
Migrated from: https://github.com/akka/akka/issues/19395#issuecomment-221261407
Many of the javadsl methods are not safe when running the same graph twice. For example, fold takes a concrete object as first parameters, such that all streams will use...
Hello, i'm using the valve component with akka-stream kafka to be able to pause and resume our kafka consumers. I discovered an issue in the current implementation when trying to...
Allow terminating a stage on actor termination or the other way around, might be useful in Akka HTTP when we want to have an actor as long as the request/response...
