On error, 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?
Yes, but recover and contine
doesn’t exist in all streaming framework as i know.
Y?
Some options to look into and see if they fit your use case listed here in the docs, recoverWith
and 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.