Package io.servicetalk.http.api
Interface ServiceDiscoveryRetryStrategy<ResolvedAddress,E extends ServiceDiscovererEvent<ResolvedAddress>>
-
- Type Parameters:
ResolvedAddress
- The type of address after resolution.E
- Type ofServiceDiscovererEvent
s published fromServiceDiscoverer.discover(Object)
.
- All Known Implementing Classes:
DefaultServiceDiscoveryRetryStrategy
- Functional Interface:
- This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public interface ServiceDiscoveryRetryStrategy<ResolvedAddress,E extends ServiceDiscovererEvent<ResolvedAddress>>
A retry strategy for errors emitted fromServiceDiscoverer.discover(Object)
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Publisher<java.util.Collection<E>>
apply(Publisher<java.util.Collection<E>> sdEvents)
Applies this strategy on the passedPublisher
.
-
-
-
Method Detail
-
apply
Publisher<java.util.Collection<E>> apply(Publisher<java.util.Collection<E>> sdEvents)
Applies this strategy on the passedPublisher
.- Parameters:
sdEvents
-Publisher
ofServiceDiscovererEvent
on which this strategy is to be applied.- Returns:
Publisher
after applying this retry strategy on the passedsdEvents
Publisher
.
-
-