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>>