akka-stream-contrib
akka-stream-contrib copied to clipboard
akka
Add-ons to Akka Stream
Not sure if it's useful to other people, but, for sure it's a nice feature to choose two flows based on the element value (of an Either, of course).
**Preconditions.** Generally, the processing of the received element from the inlet or the event from the timer results in the writing of the resulting elements to one or more outlets....
It's hard to figure out how to use Retry with Java. An example should be provided. so for I got this - please tell me how it can be improved....
### Short description Add a new shared valve, from which it would be possible to create any number of flows (with different types) all controlled by a shared switch. ###...
akka-stream module now has [`FlowWithContext`](https://doc.akka.io/docs/akka/current/stream/operators/Flow/asFlowWithContext.html#description) which should be used instead of `PassThroughFlow` from this repo.
I wrote a custom graph stage for integrating an actor to a flow in akka streams. One of the reasons for this was that I needed the actor to be...
FileTailSource and DirectoryChanges are part of Alpakka now. See - https://developer.lightbend.com/docs/alpakka/current/file.html#tailing-a-file-into-a-stream - https://developer.lightbend.com/docs/alpakka/current/file.html#listening-to-changes-in-a-directory They should be removed from this repository.
The Java API of `PartitionWith` takes a function that yields a `scala.Either`. Constructing that from Java is cumbersome. `Either.cond` comes close but by-name laziness is not retained. I would like...
