Class RetryTransformer.Context<T>

java.lang.Object

io.github.resilience4j.rxjava3.retry.transformer.RetryTransformer.Context<T>

Enclosing class:

RetryTransformer<T>

private static class RetryTransformer.Context<T>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	RetryTransformer.Context.RetryDueToResultException

Field Summary

Fields

Modifier and Type	Field	Description
private final io.github.resilience4j.retry.Retry.AsyncContext<T>	retryContext

Constructor Summary

Constructors

Constructor	Description
Context(io.github.resilience4j.retry.Retry.AsyncContext<T> retryContext)

Method Summary

Modifier and Type	Method	Description
(package private) org.reactivestreams.Publisher<Long>	handleFlowableErrors(Throwable throwable)
(package private) io.reactivex.rxjava3.core.ObservableSource<Long>	handleObservableErrors(Throwable throwable)
(package private) void	handleResult(T result)
(package private) void	onComplete()

Methods inherited from class Object

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

Field Details

retryContext

private final io.github.resilience4j.retry.Retry.AsyncContext<T> retryContext

Constructor Details

Context

Context(io.github.resilience4j.retry.Retry.AsyncContext<T> retryContext)

Method Details

onComplete

void onComplete()

handleResult

void handleResult(T result)

handleFlowableErrors

org.reactivestreams.Publisher<Long> handleFlowableErrors(Throwable throwable)

handleObservableErrors

io.reactivex.rxjava3.core.ObservableSource<Long> handleObservableErrors(Throwable throwable)