本文整理了Java中com.metamx.common.guava.Yielder.isDone()方法的一些代码示例，展示了Yielder.isDone()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Yielder.isDone()方法的具体详情如下：
包路径：com.metamx.common.guava.Yielder
类名称：Yielder
方法名：isDone

Yielder.isDone介绍

[英]Returns true if this is the last Yielder in the chain. A Yielder that isDone() may return anything from both get() and next(), there is no contract and depending on those return values will likely lead to bugs. It will probably break your code to call next() on a Yielder that is done and expect something good from it. Once next() is called on this Yielder object, all further operations on this object are undefined.
[中]如果这是链中的最后一个Yielder，则返回true。如果isDone（）可能同时返回get（）和next（）中的任何内容，则没有约定，根据这些返回值可能会导致错误。在一个已经完成的任务上调用next（）可能会破坏您的代码，并期望从中获得一些好处。在这个对象上调用next（）后，这个对象上的所有后续操作都将被取消定义。

代码示例

代码示例来源：origin: metamx/java-util

@Override
public boolean isDone()
{
 return baseYielder.isDone();
}

代码示例来源：origin: metamx/java-util

@Override
public boolean isDone()
{
 return baseYielder.isDone();
}

代码示例来源：origin: com.metamx/java-util

@Override
public boolean isDone()
{
 return baseYielder.isDone();
}

代码示例来源：origin: com.metamx/java-util

@Override
public boolean isDone()
{
 return baseYielder.isDone();
}

代码示例来源：origin: metamx/java-util

@Override
public boolean isDone()
{
 return yielder.isDone();
}

代码示例来源：origin: com.metamx/java-util

@Override
public boolean isDone()
{
 return yielder.isDone();
}

代码示例来源：origin: metamx/java-util

@Override
public boolean isDone()
{
 return !accumulator.didSomething() || yielder.isDone();
}

代码示例来源：origin: com.metamx/java-util

@Override
public boolean isDone()
{
 return !accumulator.didSomething() || yielder.isDone();
}

代码示例来源：origin: com.metamx/java-util

@Override
 public PriorityQueue<Yielder<T>> accumulate(PriorityQueue<Yielder<T>> queue, Sequence<T> in)
 {
  final Yielder<T> yielder = in.toYielder(
    null,
    new YieldingAccumulator<T, T>()
    {
     @Override
     public T accumulate(T accumulated, T in)
     {
      yield();
      return in;
     }
    }
  );
  if (!yielder.isDone()) {
   queue.add(yielder);
  } else {
   try {
    yielder.close();
   }
   catch (IOException e) {
    throw Throwables.propagate(e);
   }
  }
  return queue;
 }
}

代码示例来源：origin: metamx/java-util

@Override
 public PriorityQueue<Yielder<T>> accumulate(PriorityQueue<Yielder<T>> queue, Sequence<T> in)
 {
  final Yielder<T> yielder = in.toYielder(
    null,
    new YieldingAccumulator<T, T>()
    {
     @Override
     public T accumulate(T accumulated, T in)
     {
      yield();
      return in;
     }
    }
  );
  if (!yielder.isDone()) {
   queue.add(yielder);
  } else {
   try {
    yielder.close();
   }
   catch (IOException e) {
    throw Throwables.propagate(e);
   }
  }
  return queue;
 }
}

代码示例来源：origin: com.n3twork.druid/druid-common

@Override
public <OutType> Yielder<OutType> toYielder(OutType initValue, final YieldingAccumulator<OutType, T> accumulator)
{
 final CombiningYieldingAccumulator<OutType, T> combiningAccumulator = new CombiningYieldingAccumulator<OutType, T>(
   ordering, mergeFn, accumulator
 );
 Yielder<T> baseYielder = baseSequence.toYielder(null, combiningAccumulator);
 if (baseYielder.isDone()) {
  return Yielders.done(initValue, baseYielder);
 }
 return makeYielder(baseYielder, combiningAccumulator);
}

代码示例来源：origin: com.n3twork.druid/druid-common

@Override
 public Yielder<T> accumulate(Yielder<T> accumulated, Sequence<T> in)
 {
  final Yielder<T> retVal = in.toYielder(
    null,
    new YieldingAccumulator<T, T>()
    {
     @Override
     public T accumulate(T accumulated, T in)
     {
      yield();
      return in;
     }
    }
  );
  if (retVal.isDone()) {
   try {
    retVal.close();
   }
   catch (IOException e) {
    throw Throwables.propagate(e);
   }
   return null;
  }
  else {
   yield();
  }
  return retVal;
 }
}

代码示例来源：origin: metamx/java-util

retVal = accumulator.accumulate(retVal, yielder.get());
yielder = yielder.next(null);
if (yielder.isDone()) {
 try {
  yielder.close();

代码示例来源：origin: com.metamx/java-util

retVal = accumulator.accumulate(retVal, yielder.get());
yielder = yielder.next(null);
if (yielder.isDone()) {
 try {
  yielder.close();

代码示例来源：origin: com.metamx/java-util

public <OutType> Yielder<OutType> makeYielder(
  Yielder<Sequence<T>> yielderYielder,
  OutType initValue,
  YieldingAccumulator<OutType, T> accumulator
)
{
 if (yielderYielder.isDone()) {
  return Yielders.done(initValue, yielderYielder);
 }
 while (!yielderYielder.isDone()) {
  Yielder<OutType> yielder = yielderYielder.get().toYielder(initValue, accumulator);
  if (accumulator.yielded()) {
   return wrapYielder(yielder, yielderYielder, accumulator);
  }
  initValue = yielder.get();
  try {
   yielder.close();
  }
  catch (IOException e) {
   throw Throwables.propagate(e);
  }
  yielderYielder = yielderYielder.next(null);
 }
 return Yielders.done(initValue, yielderYielder);
}

代码示例来源：origin: metamx/java-util

public <OutType> Yielder<OutType> makeYielder(
  Yielder<Sequence<T>> yielderYielder,
  OutType initValue,
  YieldingAccumulator<OutType, T> accumulator
)
{
 if (yielderYielder.isDone()) {
  return Yielders.done(initValue, yielderYielder);
 }
 while (!yielderYielder.isDone()) {
  Yielder<OutType> yielder = yielderYielder.get().toYielder(initValue, accumulator);
  if (accumulator.yielded()) {
   return wrapYielder(yielder, yielderYielder, accumulator);
  }
  initValue = yielder.get();
  try {
   yielder.close();
  }
  catch (IOException e) {
   throw Throwables.propagate(e);
  }
  yielderYielder = yielderYielder.next(null);
 }
 return Yielders.done(initValue, yielderYielder);
}

代码示例来源：origin: com.n3twork.druid/druid-common

while (!accumulator.yielded() && (!pQueue.isEmpty() || !oldDudeAtCrosswalk.isDone())) {
 Yielder<T> yielder;
 if (oldDudeAtCrosswalk.isDone()) {
  yielder = pQueue.remove();
 if (yielder.isDone()) {
  try {
   yielder.close();

代码示例来源：origin: com.n3twork.druid/druid-common

@Override
public Yielder<OutType> next(OutType outType)
{
 T nextIn = yielder.get();
 combiningAccumulator.setRetVal(outType);
 final Yielder<T> baseYielder = yielder.next(nextIn);
 if (baseYielder.isDone()) {
  final OutType outValue = combiningAccumulator.getAccumulator().accumulate(outType, baseYielder.get());
  return Yielders.done(outValue, baseYielder);
 }
 return makeYielder(baseYielder, combiningAccumulator);
}

代码示例来源：origin: metamx/java-util

Assert.assertFalse(prefix, yielder.isDone());
  Assert.assertEquals(prefix, expectedSum, yielder.get().intValue());
Assert.assertTrue(prefix, yielder.isDone());
yielder.close();

代码示例来源：origin: metamx/java-util

while(!yielder.isDone()) {
 result.add(yielder.get());
 yielder = yielder.next(null);