recoverWith
Allow switching to alternative Source when a failure has happened upstream.
Signature
def recoverWith[T >: Out](pf: PartialFunction[Throwable, Graph[SourceShape[T], NotUsed]]): Repr[T]
Description
Allow switching to alternative Source when a failure has happened upstream.
Throwing an exception inside recoverWith
will be logged on ERROR level automatically.
emits the element is available from the upstream or upstream is failed and pf returns alternative Source
backpressures downstream backpressures, after failure happened it backprssures to alternative Source
completes upstream completes or upstream failed with exception pf can handle