How to recover akka stream with a new element?

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.