recoverWith

Allow switching to alternative Source when a failure has happened upstream.

Simple operators

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.

Reactive Streams semantics

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

Found an error in this documentation? The source code for this page can be found here. Please feel free to edit and contribute a pull request.