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

Yielders介绍

暂无

代码示例

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

@Override
 public <OutType> Yielder<OutType> toYielder(OutType initValue, YieldingAccumulator<OutType, Object> accumulator)
 {
  return Yielders.done(initValue, null);
 }
}

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

@Override
 public <OutType> Yielder<OutType> toYielder(OutType initValue, YieldingAccumulator<OutType, Object> accumulator)
 {
  return Yielders.done(initValue, null);
 }
}

代码示例来源：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: metamx/java-util

return Yielders.done(
  retVal,
  new Closeable()

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

return Yielders.done(
  retVal,
  new Closeable()

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

@Override
 public <OutType> Yielder<OutType> toYielder(OutType initValue, YieldingAccumulator<OutType, T> accumulator)
 {
  List<T> results = Sequences.toList(baseSequence, Lists.<T>newArrayList());
  final OutType retVal = accumulator.accumulate(
    initValue,
    (T) new Result<BySegmentResultValueClass<T>>(
      timestamp,
      new BySegmentResultValueClass<T>(
        results,
        segmentIdentifier,
        query.getIntervals().get(0)
      )
    )
  );
  return Yielders.done(retVal, null);
 }
};

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

return Yielders.done(retVal, null);

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

return Yielders.done(retVal, null);

代码示例来源：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

@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: com.n3twork.druid/druid-common

return Yielders.done(retVal, oldDudeAtCrosswalk);