Akka Documentation

Version 2.10.0+31-e778606c-SNAPSHOT

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

Sink.onComplete
RestartSource.onFailuresWithBackoff
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.