onErrorComplete

Allows completing the stream when an upstream error occurs.

Error handling

Signature

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

Description

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