本文整理了Java中java.util.stream.LongStream.spliterator()
方法的一些代码示例,展示了LongStream.spliterator()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。LongStream.spliterator()
方法的具体详情如下:
包路径:java.util.stream.LongStream
类名称: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;
}
内容来源于网络,如有侵权,请联系作者删除!