public class DoubleStreamDecorator extends Object implements DoubleStream
DoubleStreamDecorator wraps a Java DoubleStream and registers a closeHandler
which is passed further to any resulting Stream.
The goal of the DoubleStreamDecorator is to close the underlying DoubleStream upon
calling a terminal operation.
DoubleStream.Builder| Constructor and Description |
|---|
DoubleStreamDecorator(DoubleStream delegate,
Runnable closeHandler) |
public DoubleStreamDecorator(DoubleStream delegate, Runnable closeHandler)
public DoubleStream filter(DoublePredicate predicate)
filter in interface DoubleStreampublic DoubleStream map(DoubleUnaryOperator mapper)
map in interface DoubleStreampublic <U> Stream<U> mapToObj(DoubleFunction<? extends U> mapper)
mapToObj in interface DoubleStreampublic IntStream mapToInt(DoubleToIntFunction mapper)
mapToInt in interface DoubleStreampublic LongStream mapToLong(DoubleToLongFunction mapper)
mapToLong in interface DoubleStreampublic DoubleStream flatMap(DoubleFunction<? extends DoubleStream> mapper)
flatMap in interface DoubleStreampublic DoubleStream distinct()
distinct in interface DoubleStreampublic DoubleStream sorted()
sorted in interface DoubleStreampublic DoubleStream peek(DoubleConsumer action)
peek in interface DoubleStreampublic DoubleStream limit(long maxSize)
limit in interface DoubleStreampublic DoubleStream skip(long n)
skip in interface DoubleStreampublic void forEach(DoubleConsumer action)
forEach in interface DoubleStreampublic void forEachOrdered(DoubleConsumer action)
forEachOrdered in interface DoubleStreampublic double[] toArray()
toArray in interface DoubleStreampublic double reduce(double identity,
DoubleBinaryOperator op)
reduce in interface DoubleStreampublic OptionalDouble reduce(DoubleBinaryOperator op)
reduce in interface DoubleStreampublic <R> R collect(Supplier<R> supplier, ObjDoubleConsumer<R> accumulator, BiConsumer<R,R> combiner)
collect in interface DoubleStreampublic double sum()
sum in interface DoubleStreampublic OptionalDouble min()
min in interface DoubleStreampublic OptionalDouble max()
max in interface DoubleStreampublic long count()
count in interface DoubleStreampublic OptionalDouble average()
average in interface DoubleStreampublic DoubleSummaryStatistics summaryStatistics()
summaryStatistics in interface DoubleStreampublic boolean anyMatch(DoublePredicate predicate)
anyMatch in interface DoubleStreampublic boolean allMatch(DoublePredicate predicate)
allMatch in interface DoubleStreampublic boolean noneMatch(DoublePredicate predicate)
noneMatch in interface DoubleStreampublic OptionalDouble findFirst()
findFirst in interface DoubleStreampublic OptionalDouble findAny()
findAny in interface DoubleStreampublic Stream<Double> boxed()
boxed in interface DoubleStreampublic DoubleStream sequential()
sequential in interface BaseStream<Double,DoubleStream>sequential in interface DoubleStreampublic DoubleStream parallel()
parallel in interface BaseStream<Double,DoubleStream>parallel in interface DoubleStreampublic DoubleStream unordered()
unordered in interface BaseStream<Double,DoubleStream>public DoubleStream onClose(Runnable closeHandler)
onClose in interface BaseStream<Double,DoubleStream>public void close()
close in interface AutoCloseableclose in interface BaseStream<Double,DoubleStream>public PrimitiveIterator.OfDouble iterator()
iterator in interface BaseStream<Double,DoubleStream>iterator in interface DoubleStreampublic Spliterator.OfDouble spliterator()
spliterator in interface BaseStream<Double,DoubleStream>spliterator in interface DoubleStreampublic boolean isParallel()
isParallel in interface BaseStream<Double,DoubleStream>Copyright © 2001-2022 Red Hat, Inc. All Rights Reserved.