Recover will catch an exception coming from upstream and continue by
emitting a single element before completing. Indeed does not sound like
what you are after.
Maybe the retry stream in akka-stream-contrib could give you some
inspiration on how to solve your problem:
https://github.com/akka/akka-
Hey all,
In my example below I have a source queue. In the middle I have a flow that
can fail for a few different network related reason and all I want to do is
drop the request back in the top of the funnel. But I am not entirely sure
how I can get access to the element that went into the flow