recover only emit a final element and terminate.
But how to continue if the error is in control?
I think waht you want is
recoverWithContinue like thing?
recover and contine doesn’t exist in all streaming framework as i know.
Some options to look into and see if they fit your use case listed here in the docs,
RestartSource seems worth looking at.
I think you can make use of Error Handling in Streams • Akka Documentation, but not all stream operator support that.
Seems not meet my requirements… Thanks anyway.