com.google.common.collect.Iterators#contains ( )源码实例Demo

@Override
public void reduce(final DeletionRequest deletionRequest, ReducerInput<Boolean> values) {
  final boolean hasNoActiveReferences = !Iterators.contains(values, true);
  logger.atInfo().log("Processing async deletion request for %s", deletionRequest.key());
  DeletionResult result =
      tm()
          .transactNew(
              () -> {
                DeletionResult deletionResult =
                    attemptToDeleteResource(deletionRequest, hasNoActiveReferences);
                getQueue(QUEUE_ASYNC_DELETE).deleteTask(deletionRequest.task());
                return deletionResult;
              });
  asyncTaskMetrics.recordAsyncFlowResult(
      deletionRequest.getMetricOperationType(),
      result.getMetricOperationResult(),
      deletionRequest.requestedTime());
  String resourceNamePlural = deletionRequest.key().getKind() + "s";
  getContext().incrementCounter(result.type().renderCounterText(resourceNamePlural));
  logger.atInfo().log(
      "Result of async deletion for resource %s: %s",
      deletionRequest.key(), result.pollMessageText());
}
 

@Override
public boolean contains(Object o) {
    if (!(o instanceof TimeSeriesCollection))
        return false;
    ObjectSequence<TimeSeriesCollection> seq = getSequence();
    final EqualRange range = seq.equalRange(tsc -> tsc.compareTo((TimeSeriesCollection) o));
    if (range.isEmpty())
        return false;
    seq = seq.limit(range.getEnd()).skip(range.getBegin());
    return Iterators.contains(seq.iterator(), o);
}
 

@ExpectWarning(value="GC", num=5)
public static void testIterators(Iterator<String> i, Collection<Integer> c) {
    Iterators.contains(i, 1);
    Iterators.removeAll(i,c);
    Iterators.retainAll(i, c);
    Iterators.elementsEqual(i, c.iterator());
    Iterators.frequency(i, 1);
}
 

@NoWarning("GC")
public static void testIteratorsOK(Iterator<String> i, Collection<String> c) {
    Iterators.contains(i, "x");
    Iterators.removeAll(i,c);
    Iterators.retainAll(i, c);
    Iterators.elementsEqual(i, c.iterator());
    Iterators.frequency(i, "x");
}
 

@Override
public boolean contains(Object o) {
	return o != null && Iterators.contains(this.iterator(), o);
}
 

@Override
public boolean contains(Object o) {
	return o != null && Iterators.contains(this.iterator(), o);
}
 

@Override
public boolean contains(Object o) {
    return Iterators.contains(iterator(), o);
}
 

@Override
@SuppressWarnings("checkstyle:parameterName")
public boolean contains(final Object o) {
    final PathArgument srch = (PathArgument) requireNonNull(o);
    return Iterators.contains(iterator(), srch);
}