Module mutiny.zero

Package mutiny.zero.operators

Class Recover<T>

java.lang.Object

mutiny.zero.operators.Recover<T>

Type Parameters:

T - the elements type

All Implemented Interfaces:

Flow.Publisher<T>

public class Recover<T>
extends Object
implements Flow.Publisher<T>

A Flow.Publisher that recovers from failure using a Function.

The provided function accepts an error that would normally trigger an Flow.Subscriber.onError(Throwable) signal.

The function returns a recovery value of type T, then the stream terminates with an Flow.Subscriber.onComplete() signal. If the function returns null then the stream terminates directly with a completion event.

The stream ends with an error if the function throws an exception.

Constructor Summary

Constructors

Constructor	Description
Recover(Flow.Publisher<T> upstream, Function<Throwable,T> function)	Build a new recovery publisher.

Method Summary

Modifier and Type	Method	Description
void	subscribe(Flow.Subscriber<? super T> subscriber)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Recover

public Recover(Flow.Publisher<T> upstream,
 Function<Throwable,T> function)

Build a new recovery publisher.

Parameters:

upstream - the upstream publisher

function - the recovery function, must not return null values

Method Details

subscribe

public void subscribe(Flow.Subscriber<? super T> subscriber)

Specified by:

subscribe in interface Flow.Publisher<T>