ResolvedAddress
- The type of address after resolution.E
- Type of ServiceDiscovererEvent
s published from ServiceDiscoverer.discover(Object)
.public final class DefaultServiceDiscoveryRetryStrategy<ResolvedAddress,E extends ServiceDiscovererEvent<ResolvedAddress>> extends java.lang.Object implements ServiceDiscoveryRetryStrategy<ResolvedAddress,E>
ServiceDiscoveryRetryStrategy
.Modifier and Type | Class and Description |
---|---|
static class |
DefaultServiceDiscoveryRetryStrategy.Builder<ResolvedAddress,E extends ServiceDiscovererEvent<ResolvedAddress>>
A builder to build instances of
DefaultServiceDiscoveryRetryStrategy . |
Modifier and Type | Method and Description |
---|---|
Publisher<java.util.Collection<E>> |
apply(Publisher<java.util.Collection<E>> sdEvents)
Applies this strategy on the passed
Publisher . |
public Publisher<java.util.Collection<E>> apply(Publisher<java.util.Collection<E>> sdEvents)
ServiceDiscoveryRetryStrategy
Publisher
.apply
in interface ServiceDiscoveryRetryStrategy<ResolvedAddress,E extends ServiceDiscovererEvent<ResolvedAddress>>
sdEvents
- Publisher
of ServiceDiscovererEvent
on which this strategy is to be applied.Publisher
after applying this retry strategy on the passed sdEvents
Publisher
.