blueflood-core/src/main/java/com/rackspacecloud/blueflood/inputs/processors/TokenDiscoveryWriter.java
static List<Locator> getLocators(final List<List<IMetric>> input) {

        //converting list of lists of metrics to flat list of locators that are not current.
        return input.stream()
                    .flatMap(List::stream)
                    .map(IMetric::getLocator)
                    .filter(locator -> !LocatorCache.getInstance().isLocatorCurrentInTokenDiscoveryLayer(locator))
                    .collect(toList());
    }
static List<Locator> getLocators(final List<List<IMetric>> input) {

        //converting list of lists of metrics to flat list of locators that are not current.
        return input.stream()
                    .flatMap(List::stream)
                    .map(IMetric::getLocator)
                    .filter(locator -> !LocatorCache.getInstance().isLocatorCurrentInTokenDiscoveryLayer(locator))
                    .collect(toList());
    }
Get all {@link Locator}'s corresponding to the metrics which are not current.

@param input
@return