UnresolvedAddress- The type of address before resolution.
ResolvedAddress- The type of address after resolution.
Event- Type of
ServiceDiscovererEvents published from
public class ServiceDiscovererFilter<UnresolvedAddress,ResolvedAddress,Event extends ServiceDiscovererEvent<ResolvedAddress>> extends java.lang.Object implements ServiceDiscoverer<UnresolvedAddress,ResolvedAddress,Event>
ServiceDiscovererthat delegates all methods to a different
|Constructor and Description|
Create a new instance.
|Modifier and Type||Method and Description|
Used to close/shutdown a resource.
Used to close/shutdown a resource, similar to
Subscribe to the service discovery system for changes in the available
public ServiceDiscovererFilter(ServiceDiscoverer<UnresolvedAddress,ResolvedAddress,Event> delegate)
ServiceDiscovererto delegate all calls to.
public Publisher<Event> discover(UnresolvedAddress unresolvedAddress)
In general a call to this method will continue to discover changes related to
address until the
corresponding to the return value is cancelled via
Cancellable.cancel() or there are no more changes to
ServiceDiscoverer<UnresolvedAddress,ResolvedAddress,Event extends ServiceDiscovererEvent<ResolvedAddress>>
unresolvedAddress- the service address to discover. Examples of what this address maybe are:
Publisherthat represents a stream of events from the service discovery system.
public Completable onClose()
Completablethat is notified once the
Completablethat is notified on close.
public Completable closeAsync()
CompletableSourcethat is notified once the close is complete.
public Completable closeAsyncGracefully()
AsyncCloseable.closeAsync(), but attempts to cleanup state before abruptly closing. This provides a hint that implementations can use to stop accepting new work and finish in flight work. This method is implemented on a "best effort" basis and may be equivalent to
Note: Implementations may or may not apply a timeout for this operation to complete, if a caller does not
want to wait indefinitely, and are unsure if the implementation applies a timeout, it is advisable to apply a
timeout and force a call to
Completablethat is notified once the close is complete.