Module mutiny.zero

Package mutiny.zero.operators

Class Retry<T>

java.lang.Object

mutiny.zero.operators.Retry<T>

Type Parameters:

T - the elements type

All Implemented Interfaces:

Flow.Publisher<T>

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

A Flow.Publisher that retries on failure by re-subscribing to its upstream. A Predicate controls when to retry, and when to stop retrying.

Note: this retry operator does not perform advanced time-based re-subscriptions (e.g., exponential back-off).

Constructor Summary

Constructors

Constructor	Description
Retry(Flow.Publisher<T> upstream, Predicate<Throwable> retryPredicate)	Build a new retry publisher.

Method Summary

Modifier and Type	Method	Description
static Predicate<Throwable>	always()
static Predicate<Throwable>	atMost(int count)
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

Retry

public Retry(Flow.Publisher<T> upstream,
 Predicate<Throwable> retryPredicate)

Build a new retry publisher.

Parameters:

upstream - the upstream publisher

retryPredicate - the retry predicate

Method Details

always

public static Predicate<Throwable> always()

atMost

public static Predicate<Throwable> atMost(int count)

subscribe

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

Specified by:

subscribe in interface Flow.Publisher<T>