onErrorResume

Allows transforming a failure signal into a stream of elements provided by a factory function.

Error handling

This method is Java API only, use recoverWith in Scala.

Signature

Source.onErrorResumeSource.onErrorResume
Source.onErrorResumeSource.onErrorResume
Source.onErrorResumeSource.onErrorResume
Flow.onErrorResumeFlow.onErrorResume
Flow.onErrorResumeFlow.onErrorResume
Flow.onErrorResumeFlow.onErrorResume

Description

Transform a failure signal into a stream of elements provided by a factory function.

Reactive Streams semantics

emits element is available from the upstream or upstream is failed and fallback Source produces an element

backpressures downstream backpressures

completes upstream completes or upstream failed with exception and fallback Source completes

Cancels when downstream cancels

2.0.0-M0+158-57812486*