java类com.google.common.collect.Iterators的实例源码

@Test
public void testFindHistoryFilePath() throws Exception {

  final Iterator<LocatedFileStatus> mockListing = Iterators.forArray(
      mockFileStatus("/foobar.jhist"),
      mockFileStatus("/barbaz.jhist"),
      mockFileStatus("/a.log"),
      mockFileStatus("/" + DUMMY_JHIST_NAME));

  Optional<String> jHistFile = HistoryLogUtils.findHistoryFilePath(mockListing,
      ApplicationId.newInstance(DUMMY_ID_TIMESTAMP, DUMMY_ID_SERIAL));

  assertTrue(jHistFile.isPresent());
  assertEquals("/" + DUMMY_JHIST_NAME, jHistFile.get());
}

@Test
public void testNoHistoryFound() throws Exception {

  final Iterator<LocatedFileStatus> mockListing = Iterators.forArray(
      mockFileStatus("/a.log"));

  Optional<String> jHistFile = HistoryLogUtils.findHistoryFilePath(mockListing,
      ApplicationId.newInstance(DUMMY_ID_TIMESTAMP, DUMMY_ID_SERIAL));

  assertFalse(jHistFile.isPresent());
}

/**
 * @return all system options that have been set to a non-default value
 */
public OptionList getNonDefaultOptions() {
  Iterator<OptionValue> persistedOptions = Iterators.transform(this.options.getAll(), EXTRACT_OPTIONS);

  OptionList nonDefaultOptions = new OptionList();
  Iterators.addAll(nonDefaultOptions, persistedOptions);
  return nonDefaultOptions;
}

@Override
public Iterator<Tree> childrenIterator() {
  return Iterators.concat(
    Iterators.forArray(openParenthesis, parameter, colon),
    values.iterator(),
    Iterators.singletonIterator(closeParenthesis));
}

@Override
public Iterator<Tree> childrenIterator() {
  return Iterators.concat(
    Iterators.singletonIterator(openParenthesis),
    entries.elementsAndSeparators(Function.identity(), Function.identity()),
    Iterators.singletonIterator(closeParenthesis));
}

private static int updateColumn(int columnI, String originalTokText) {
    Integer last = Iterators.getLast(Newlines.lineOffsetIterator(originalTokText));
    if (last > 0) {
        columnI = originalTokText.length() - last;
    } else {
        columnI += originalTokText.length();
    }
    return columnI;
}

static void writeMultiDexDirectorySingleThread(boolean multiDex, File directory, DexFileNameIterator nameIterator,
        DexFile dexFile, int minMainDexClassCount, boolean minimalMainDex, int maxDexPoolSize, DexIO.Logger logger)
        throws IOException {
    Set<? extends ClassDef> classes = dexFile.getClasses();
    if (!multiDex) {
        minMainDexClassCount = classes.size();
        minimalMainDex = false;
    }
    Object lock = new Object();
    synchronized (lock) {       // avoid multiple synchronizations in single-threaded mode
        writeMultiDexDirectoryCommon(directory, nameIterator, Iterators.peekingIterator(classes.iterator()),
                minMainDexClassCount, minimalMainDex, dexFile.getOpcodes(), maxDexPoolSize, logger, lock);
    }
}

public Iterable<CompleteFileWork> getWorkIterable() {
  return new Iterable<CompleteFileWork>() {
    @Override
    public Iterator<CompleteFileWork> iterator() {
      return Iterators.unmodifiableIterator(chunks.iterator());
    }
  };
}

public boolean contains(Object p_contains_1_)
{
    return Iterators.contains(this.getByClass(p_contains_1_.getClass()).iterator(), p_contains_1_);
}

public static boolean equals(Object[] a, Object[] b)
{
    return size(a) == size(b) && Iterators.elementsEqual(iterator(a), iterator(b));
}