mapError

While similar to recover this stage can be used to transform an error signal to a different one without logging it as an error in the process.

Simple operators

Signature

def mapError(pf: PartialFunction[Throwable, Throwable]): Repr[Out]

Description

While similar to recover this stage can be used to transform an error signal to a different one without logging it as an error in the process. So in that sense it is NOT exactly equivalent to recover(t => throw t2) since recover would log the t2 error.

Since the underlying failure signal onError arrives out-of-band, it might jump over existing elements. This stage can recover the failure signal, but not the skipped elements, which will be dropped.

Similarily to recover throwing an exception inside mapError will be logged on ERROR level automatically.

emits when element is available from the upstream or upstream is failed and pf returns an element backpressures when downstream backpressures completes when upstream completes or upstream failed with exception pf can handle

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.