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

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

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

LongStream.spliterator介绍

暂无

代码示例

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

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

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

default Spliterator.OfLong spliterator(LongPipeline pipeline) {
  requireNonNull(pipeline);
  return optimize(pipeline).getAsLongStream().spliterator();
}

代码示例来源:origin: google/guava

/**
 * Appends all values from {@code stream}, in order, to the end of the values the built {@link
 * ImmutableLongArray} will contain.
 */
public Builder addAll(LongStream stream) {
 Spliterator.OfLong spliterator = stream.spliterator();
 long size = spliterator.getExactSizeIfKnown();
 if (size > 0) { // known *and* nonempty
  ensureRoomFor(Ints.saturatedCast(size));
 }
 spliterator.forEachRemaining((LongConsumer) this::add);
 return this;
}

代码示例来源:origin: prestodb/presto

/**
 * Appends all values from {@code stream}, in order, to the end of the values the built {@link
 * ImmutableLongArray} will contain.
 */
public Builder addAll(LongStream stream) {
 Spliterator.OfLong spliterator = stream.spliterator();
 long size = spliterator.getExactSizeIfKnown();
 if (size > 0) { // known *and* nonempty
  ensureRoomFor(Ints.saturatedCast(size));
 }
 spliterator.forEachRemaining((LongConsumer) this::add);
 return this;
}

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

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

代码示例来源:origin: google/guava

checkNotNull(function);
boolean isParallel = stream.isParallel();
Spliterator.OfLong fromSpliterator = stream.spliterator();

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

/**
 * Appends all values from {@code stream}, in order, to the end of the values the built {@link
 * ImmutableLongArray} will contain.
 */
public Builder addAll(LongStream stream) {
 Spliterator.OfLong spliterator = stream.spliterator();
 long size = spliterator.getExactSizeIfKnown();
 if (size > 0) { // known *and* nonempty
  ensureRoomFor(Ints.saturatedCast(size));
 }
 spliterator.forEachRemaining((LongConsumer) this::add);
 return this;
}

代码示例来源:origin: google/j2objc

checkNotNull(function);
boolean isParallel = stream.isParallel();
Spliterator.OfLong fromSpliterator = stream.spliterator();

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

checkNotNull(function);
boolean isParallel = stream.isParallel();
Spliterator.OfLong fromSpliterator = stream.spliterator();

代码示例来源:origin: prestodb/presto

checkNotNull(function);
boolean isParallel = stream.isParallel();
Spliterator.OfLong fromSpliterator = stream.spliterator();

代码示例来源:origin: aol/cyclops

/**
 * Peform intermediate operations on a primitive IntStream (gives improved performance when working with Integers)
 * If this ReactiveSeq has an OfInt Spliterator it will be converted directly to an IntStream,
 * otherwise the provided conversion function will be used.
 *
 * <pre>
 * {@code
 * ReactiveSeq.range(1, 1000)
 *            .longs(i->i.longValue(),s->s.map(i->i*2).filter(i->i<500))
       .size(),
  //249
 *
 * </pre>
 *
 *
 * @param fn
 * @param mapper
 * @return
 */
default ReactiveSeq<Long> longs(ToLongFunction<? super T> fn,Function<? super LongStream, ? extends LongStream> mapper){
  return ReactiveSeq.fromSpliterator(mapper.apply(mapToLong(fn)).spliterator());
}

代码示例来源:origin: aol/cyclops

@Deprecated //moved to cyclops.companion.Functions
public static Function<? super ReactiveSeq<Long>, ? extends ReactiveSeq<Long>> concatLongs( ReactiveSeq<Long> b){
  return a->fromSpliterator(LongStream.concat(a.mapToLong(i->i),b.mapToLong(i->i)).spliterator());
}

代码示例来源:origin: aol/cyclops

public static Function<? super ReactiveSeq<Long>, ? extends ReactiveSeq<Long>> concatLongs( ReactiveSeq<Long> b){
  return a->ReactiveSeq.fromSpliterator(LongStream.concat(a.mapToLong(i->i),b.mapToLong(i->i)).spliterator());
}

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

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

代码示例来源:origin: soabase/soabase-halva

@Override
public For forCompLong(AnyVal<Long> any, Supplier<LongStream> stream)
{
  streamFor.forComp(any, () -> StreamSupport.stream(stream.get().spliterator(), false));
  return this;
}

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

default Spliterator.OfLong spliterator(LongPipeline pipeline) {
  requireNonNull(pipeline);
  return optimize(pipeline).getAsLongStream().spliterator();
}

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

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

代码示例来源:origin: com.oath.cyclops/cyclops

@Deprecated //moved to cyclops.companion.Functions
public static Function<? super ReactiveSeq<Long>, ? extends ReactiveSeq<Long>> concatLongs( ReactiveSeq<Long> b){
  return a->fromSpliterator(LongStream.concat(a.mapToLong(i->i),b.mapToLong(i->i)).spliterator());
}

代码示例来源:origin: org.apache.hbase.thirdparty/hbase-shaded-miscellaneous

/**
 * Appends all values from {@code stream}, in order, to the end of the values the built {@link
 * ImmutableLongArray} will contain.
 */
public Builder addAll(LongStream stream) {
 Spliterator.OfLong spliterator = stream.spliterator();
 long size = spliterator.getExactSizeIfKnown();
 if (size > 0) { // known *and* nonempty
  ensureRoomFor(Ints.saturatedCast(size));
 }
 spliterator.forEachRemaining((LongConsumer) this::add);
 return this;
}

代码示例来源:origin: io.prestosql/presto-jdbc

/**
 * Appends all values from {@code stream}, in order, to the end of the values the built {@link
 * ImmutableLongArray} will contain.
 */
public Builder addAll(LongStream stream) {
 Spliterator.OfLong spliterator = stream.spliterator();
 long size = spliterator.getExactSizeIfKnown();
 if (size > 0) { // known *and* nonempty
  ensureRoomFor(Ints.saturatedCast(size));
 }
 spliterator.forEachRemaining((LongConsumer) this::add);
 return this;
}

相关文章

微信公众号

最新文章

更多