Allows completing the stream when an upstream error occurs.

Error handling


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


Allows to complete the stream when an upstream error occurs.

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.