Allows completing the stream when a upstream error occur.

Error handling


Source.onErrorCompleteSource.onErrorComplete Source.onErrorCompleteSource.onErrorComplete Flow.onErrorCompleteFlow.onErrorComplete Flow.onErrorCompleteFlow.onErrorComplete


Allows to complete the stream when an upstream error occur.

Reactive Streams semantics

emits element is available from the upstream

backpressures downstream backpressures

completes upstream completes or upstream failed with exception this operator can handle

Cancels when downstream cancels

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.