io.servicetalk.client.api.internal

Class ServiceDiscovererUtils

java.lang.Object

io.servicetalk.client.api.internal.ServiceDiscovererUtils

public final class ServiceDiscovererUtils
extends java.lang.Object

A set of utility functions for ServiceDiscoverer.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ServiceDiscovererUtils.TwoIntsConsumer Represents an operation that accepts two int-valued arguments and returns no result.

Method Summary

Modifier and Type	Method and Description
static <T> java.util.List<ServiceDiscovererEvent<T>>	calculateDifference(java.util.List<? extends T> currentActiveAddresses, java.util.List<? extends T> newActiveAddresses, java.util.Comparator<T> comparator, ServiceDiscovererUtils.TwoIntsConsumer reporter) Given a sorted list of currently active addresses, and a new set of unsorted active address calculate the ServiceDiscovererEvents.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

calculateDifference

@Nullable
public static <T> java.util.List<ServiceDiscovererEvent<T>> calculateDifference(java.util.List<? extends T> currentActiveAddresses,
                                                                                          java.util.List<? extends T> newActiveAddresses,
                                                                                          java.util.Comparator<T> comparator,
                                                                                          @Nullable
                                                                                          ServiceDiscovererUtils.TwoIntsConsumer reporter)

Given a sorted list of currently active addresses, and a new set of unsorted active address calculate the ServiceDiscovererEvents.

newActiveAddresses will be sorted in this method.

Type Parameters:

T - The type of address.

Parameters:

currentActiveAddresses - The currently active addresses.

newActiveAddresses - The new list of active addresses.This list must be modifiable as it will be sorted with List.sort(Comparator).

comparator - A comparator for the addresses and to use for binary searches.

reporter - A reporter for the numbers of available and unavailable events.

Returns:

A list of ServiceDiscovererEvents which represents the changes between currentActiveAddresses and newActiveAddresses, or null if there are no changes.