onErrorContinue

Continues the stream when an upstream error occurs.

Error handling

Signature

Source.onErrorContinueSource.onErrorContinue Flow.onErrorContinueFlow.onErrorContinue

Source.onErrorContinueSource.onErrorContinue Source.onErrorContinueSource.onErrorContinue Flow.onErrorContinueFlow.onErrorContinue Flow.onErrorContinueFlow.onErrorContinue

Description

Continues the stream when an upstream error occurs.

When an error is signaled from upstream, the errorConsumer function is invoked with the Throwable, and the stream resumes processing subsequent elements. The element that caused the error is dropped.

Which errors are handled can be restricted by the type parameter Tby passing a Class, or by passing a predicate p that decides for each error whether it should be handled. Errors that are not handled fail the stream as usual.

This operator relies on supervision, so it has no effect on operators that do not support supervision.

Reactive Streams semantics