Class AbstractRetry<T,S>

java.lang.Object
com.couchbase.client.core.retry.reactor.AbstractRetry<T,S>
All Implemented Interfaces:
Function<Flux<S>,org.reactivestreams.Publisher<Long>>
Direct Known Subclasses:
DefaultRepeat, DefaultRetry

public abstract class AbstractRetry<T,S> extends Object implements Function<Flux<S>,org.reactivestreams.Publisher<Long>>