Re: [akka-user] Akka queue stream recover and drop element back in top

2017-04-25 Thread Akka Team
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-

[akka-user] Akka queue stream recover and drop element back in top

2017-04-09 Thread scallahan via Akka User List
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