java.util.stream.LongStream.iterator()方法的使用及代码示例

x33g5p2x  于2022-01-23 转载在 其他  
字(6.2k)|赞(0)|评价(0)|浏览(132)

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

LongStream.iterator介绍

暂无

代码示例

代码示例来源:origin: neo4j/neo4j

public PrimitiveIterator.OfLong primitiveIterator()
{
  return inner.iterator();
}

代码示例来源:origin: speedment/speedment

@Override
  public PrimitiveIterator.OfLong execute() {
    try (final LongStream stream = buildPrevious()) {
      return stream.iterator();
    }
  }
}

代码示例来源:origin: neo4j/neo4j

return LongStream.of( (long[]) o ).iterator();

代码示例来源:origin: speedment/speedment

default PrimitiveIterator.OfLong iterator(LongPipeline pipeline) {
  requireNonNull(pipeline);
  return optimize(pipeline).getAsLongStream().iterator();
}

代码示例来源:origin: neo4j/neo4j

return ((LongStream) iterable).iterator();

代码示例来源:origin: speedment/speedment

@Override
public PrimitiveIterator.OfLong iterator() {
  if (isAllowStreamIteratorAndSpliterator()) {
    return stream().iterator();
  }
  throw newUnsupportedException("iterator");
}

代码示例来源:origin: ben-manes/caffeine

/** Broadcast the trace events to all of the policy actors. */
private void broadcast() {
 try (LongStream events = eventStream()) {
  LongArrayList batch = new LongArrayList(batchSize);
  for (PrimitiveIterator.OfLong i = events.iterator(); i.hasNext();) {
   batch.add(i.nextLong());
   if (batch.size() == batchSize) {
    router.route(batch, self());
    batch = new LongArrayList(batchSize);
   }
  }
  router.route(batch, self());
  router.route(FINISH, self());
 } catch (Exception e) {
  context().system().log().error(e, "");
  context().stop(self());
 }
}

代码示例来源:origin: org.neo4j/neo4j-cypher

public PrimitiveIterator.OfLong primitiveIterator()
{
  return inner.iterator();
}

代码示例来源:origin: stackoverflow.com

static LongUnaryOperator factorial = x -> x == 0 ? 1
                   : x * factorial.applyAsLong(x - 1);

public static void main(String[] args) {
  LongStream ls = LongStream.iterate(0, i -> i + 1).map(factorial);
  OfLong it = ls.iterator();
  long next = 0;
  while ((next = it.nextLong()) <= 1000) System.out.println(next);
}

代码示例来源:origin: se.ugli.ugli-commons/ugli-commons

@Override
public OfLong iterator() {
  // This is a terminal operation
  return evalAndclose(() -> stream.iterator());
}

代码示例来源:origin: com.bazaarvoice.emodb/emodb-common-dropwizard

RandomExpirationSupplier(Supplier<T> delegate, long minDuration, long maxDuration, TimeUnit timeUnit) {
  checkArgument(minDuration >= 0, "minDuration cannot be negative");
  checkArgument(maxDuration > minDuration, "maxDuration must be greater than minDuration");
  checkNotNull(delegate, "delegate");
  checkNotNull(timeUnit, "timeUnit");
  long minDurationNanos = timeUnit.toNanos(minDuration);
  long maxDurationNanos = timeUnit.toNanos(maxDuration);
  _delegate = delegate;
  _nanosDurations = new Random().longs(minDurationNanos, maxDurationNanos).iterator();
}

代码示例来源:origin: bazaarvoice/emodb

RandomExpirationSupplier(Supplier<T> delegate, long minDuration, long maxDuration, TimeUnit timeUnit) {
  checkArgument(minDuration >= 0, "minDuration cannot be negative");
  checkArgument(maxDuration > minDuration, "maxDuration must be greater than minDuration");
  checkNotNull(delegate, "delegate");
  checkNotNull(timeUnit, "timeUnit");
  long minDurationNanos = timeUnit.toNanos(minDuration);
  long maxDurationNanos = timeUnit.toNanos(maxDuration);
  _delegate = delegate;
  _nanosDurations = new Random().longs(minDurationNanos, maxDurationNanos).iterator();
}

代码示例来源:origin: co.unruly/java-8-matchers

@Override
  protected boolean matchesSafely(LongStream actual) {
    return remainingItemsEqual(expected.limit(limit).iterator(), actual.limit(limit).iterator());
  }
};

代码示例来源:origin: com.speedment.runtime/runtime-core

default PrimitiveIterator.OfLong iterator(LongPipeline pipeline) {
  requireNonNull(pipeline);
  return optimize(pipeline).getAsLongStream().iterator();
}

代码示例来源:origin: co.unruly/java-8-matchers

@Override
  protected boolean matchesSafely(LongStream actual) {
    return remainingItemsEqual(new LongArrayIterator(expected), actual.limit(expected.length).iterator());
  }
};

代码示例来源:origin: com.speedment.runtime/runtime-core

@Override
public PrimitiveIterator.OfLong iterator() {
  if (isAllowStreamIteratorAndSpliterator()) {
    return stream().iterator();
  }
  throw newUnsupportedException("iterator");
}

代码示例来源:origin: osmlab/atlas

private Location[] getTwoNodes(final PackedAtlas packedAtlas, final long size)
  {
    final OfLong iterator = this.random.longs(0, size).iterator();
    final long index1 = iterator.next();
    final long index2 = iterator.next();
    final Location[] result = new Location[2];
    result[0] = packedAtlas.nodeLocation(index1);
    result[1] = packedAtlas.nodeLocation(index2);
    return result;
  }
}

代码示例来源:origin: FoundationDB/fdb-record-layer

@ValueSource(ints = {1, 2, 3, 4, 11})
@ParameterizedTest(name = "multipleOverlappingUnionWithInnerLimits() [{0}]")
public void multipleOverlappingUnionWithInnerLimits(int innerLimit) throws Exception {
  verifyUnionWithInnerLimits(Arrays.asList(
      cont -> scanRecordsBetween(10L, 20L, cont).limitRowsTo(innerLimit)
          .map(rec -> (FDBRecord<Message>) rec),
      cont -> scanRecordsBetween(9L, 15L, cont).limitRowsTo(innerLimit)
          .map(rec -> (FDBRecord<Message>) rec),
      cont -> scanRecordsBetween(14L, 25L, cont).limitRowsTo(innerLimit)
          .map(rec -> (FDBRecord<Message>) rec)
  ), LongStream.range(9L, 25L).iterator());
}

代码示例来源:origin: FoundationDB/fdb-record-layer

@ValueSource(ints = {1, 2, 3})
@ParameterizedTest(name = "overlappingUnionWithInnerLimits() [{0}]")
public void overlappingUnionWithInnerLimits(int innerLimit) throws Exception {
  verifyUnionWithInnerLimits(cont -> scanRecordsBetween(10L, 53L, cont).limitRowsTo(innerLimit)
          .map(rec -> (FDBRecord<Message>) rec),
      cont -> scanRecordsBetween(50L, 62L, cont).limitRowsTo(innerLimit)
          .map(rec -> (FDBRecord<Message>) rec),
      LongStream.range(10L, 62L).iterator());
}

代码示例来源:origin: FoundationDB/fdb-record-layer

@ValueSource(ints = {1, 2, 3})
@ParameterizedTest(name = "disjointUnionWithInnerLimits() [{0}]")
public void disjointUnionWithInnerLimits(int innerLimit) throws Exception {
  verifyUnionWithInnerLimits(cont -> scanRecordsBetween(10L, 22L, cont).limitRowsTo(innerLimit)
          .map(rec -> (FDBRecord<Message>) rec),
      cont -> scanRecordsBetween(50L, 62L, cont).limitRowsTo(innerLimit)
          .map(rec -> (FDBRecord<Message>) rec),
      LongStream.concat(LongStream.range(10L, 22L), LongStream.range(50L, 62L)).iterator());
}

相关文章

微信公众号

最新文章

更多