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?