ResolvedAddress
- The type of address after resolution.E
- Type of ServiceDiscovererEvent
s published from ServiceDiscoverer.discover(Object)
.@FunctionalInterface
public interface ServiceDiscoveryRetryStrategy<ResolvedAddress,E extends ServiceDiscovererEvent<ResolvedAddress>>
ServiceDiscoverer.discover(Object)
.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 . |
Publisher<java.util.Collection<E>> apply(Publisher<java.util.Collection<E>> sdEvents)
Publisher
.sdEvents
- Publisher
of ServiceDiscovererEvent
on which this strategy is to be applied.Publisher
after applying this retry strategy on the passed sdEvents
Publisher
.