public class LocalDoubleCacheStream extends AbstractLocalCacheStream<Double,DoubleStream> implements DoubleStream
AbstractLocalCacheStream.StreamSupplier<R>
DoubleStream.Builder
intermediateOperations, keysToFilter, log, onCloseRunnables, parallel, registry, segmentsToFilter, streamSupplier
Constructor and Description |
---|
LocalDoubleCacheStream(AbstractLocalCacheStream.StreamSupplier streamSupplier,
boolean parallel,
ComponentRegistry registry) |
close, createStream, isParallel, onClose, parallel, sequential, unordered
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
builder, concat, empty, generate, iterate, of, of, parallel, sequential
close, isParallel, onClose, unordered
public LocalDoubleCacheStream(AbstractLocalCacheStream.StreamSupplier streamSupplier, boolean parallel, ComponentRegistry registry)
streamSupplier
- parallel
- registry
- public DoubleStream filter(DoublePredicate predicate)
filter
in interface DoubleStream
public DoubleStream map(DoubleUnaryOperator mapper)
map
in interface DoubleStream
public <U> Stream<U> mapToObj(DoubleFunction<? extends U> mapper)
mapToObj
in interface DoubleStream
public IntStream mapToInt(DoubleToIntFunction mapper)
mapToInt
in interface DoubleStream
public LongStream mapToLong(DoubleToLongFunction mapper)
mapToLong
in interface DoubleStream
public DoubleStream flatMap(DoubleFunction<? extends DoubleStream> mapper)
flatMap
in interface DoubleStream
public DoubleStream distinct()
distinct
in interface DoubleStream
public DoubleStream sorted()
sorted
in interface DoubleStream
public DoubleStream peek(DoubleConsumer action)
peek
in interface DoubleStream
public DoubleStream limit(long maxSize)
limit
in interface DoubleStream
public DoubleStream skip(long n)
skip
in interface DoubleStream
public void forEach(DoubleConsumer action)
forEach
in interface DoubleStream
public void forEachOrdered(DoubleConsumer action)
forEachOrdered
in interface DoubleStream
public double[] toArray()
toArray
in interface DoubleStream
public double reduce(double identity, DoubleBinaryOperator op)
reduce
in interface DoubleStream
public OptionalDouble reduce(DoubleBinaryOperator op)
reduce
in interface DoubleStream
public <R> R collect(Supplier<R> supplier, ObjDoubleConsumer<R> accumulator, BiConsumer<R,R> combiner)
collect
in interface DoubleStream
public double sum()
sum
in interface DoubleStream
public OptionalDouble min()
min
in interface DoubleStream
public OptionalDouble max()
max
in interface DoubleStream
public long count()
count
in interface DoubleStream
public OptionalDouble average()
average
in interface DoubleStream
public DoubleSummaryStatistics summaryStatistics()
summaryStatistics
in interface DoubleStream
public boolean anyMatch(DoublePredicate predicate)
anyMatch
in interface DoubleStream
public boolean allMatch(DoublePredicate predicate)
allMatch
in interface DoubleStream
public boolean noneMatch(DoublePredicate predicate)
noneMatch
in interface DoubleStream
public OptionalDouble findFirst()
findFirst
in interface DoubleStream
public OptionalDouble findAny()
findAny
in interface DoubleStream
public Stream<Double> boxed()
boxed
in interface DoubleStream
public PrimitiveIterator.OfDouble iterator()
iterator
in interface BaseStream<Double,DoubleStream>
iterator
in interface DoubleStream
public Spliterator.OfDouble spliterator()
spliterator
in interface BaseStream<Double,DoubleStream>
spliterator
in interface DoubleStream
Copyright © 2021 JBoss, a division of Red Hat. All rights reserved.