org.infinispan.stream.impl.local

Class LocalDoubleCacheStream

java.lang.Object

org.infinispan.stream.impl.local.AbstractLocalCacheStream<Double,DoubleStream>

org.infinispan.stream.impl.local.LocalDoubleCacheStream

All Implemented Interfaces:

AutoCloseable, BaseStream<Double,DoubleStream>, DoubleStream

public class LocalDoubleCacheStream
extends AbstractLocalCacheStream<Double,DoubleStream>
implements DoubleStream

DoubleStream that wraps a given stream to allow for additional functionality such as injection of values into various operations

Nested Class Summary

Nested classes/interfaces inherited from class org.infinispan.stream.impl.local.AbstractLocalCacheStream

AbstractLocalCacheStream.StreamSupplier<R>

Nested classes/interfaces inherited from interface java.util.stream.DoubleStream

DoubleStream.Builder

Field Summary

Fields inherited from class org.infinispan.stream.impl.local.AbstractLocalCacheStream

intermediateOperations, keysToFilter, log, onCloseRunnables, parallel, registry, segmentsToFilter, streamSupplier

Constructor Summary

Constructors

Constructor and Description
LocalDoubleCacheStream(AbstractLocalCacheStream.StreamSupplier streamSupplier, boolean parallel, ComponentRegistry registry)

Method Summary

Modifier and Type	Method and Description
boolean	allMatch(DoublePredicate predicate)
boolean	anyMatch(DoublePredicate predicate)
OptionalDouble	average()
Stream<Double>	boxed()
<R> R	collect(Supplier<R> supplier, ObjDoubleConsumer<R> accumulator, BiConsumer<R,R> combiner)
long	count()
DoubleStream	distinct()
DoubleStream	filter(DoublePredicate predicate)
OptionalDouble	findAny()
OptionalDouble	findFirst()
DoubleStream	flatMap(DoubleFunction<? extends DoubleStream> mapper)
void	forEach(DoubleConsumer action)
void	forEachOrdered(DoubleConsumer action)
PrimitiveIterator.OfDouble	iterator()
DoubleStream	limit(long maxSize)
DoubleStream	map(DoubleUnaryOperator mapper)
IntStream	mapToInt(DoubleToIntFunction mapper)
LongStream	mapToLong(DoubleToLongFunction mapper)
<U> Stream<U>	mapToObj(DoubleFunction<? extends U> mapper)
OptionalDouble	max()
OptionalDouble	min()
boolean	noneMatch(DoublePredicate predicate)
DoubleStream	peek(DoubleConsumer action)
OptionalDouble	reduce(DoubleBinaryOperator op)
double	reduce(double identity, DoubleBinaryOperator op)
DoubleStream	skip(long n)
DoubleStream	sorted()
Spliterator.OfDouble	spliterator()
double	sum()
DoubleSummaryStatistics	summaryStatistics()
double[]	toArray()

Methods inherited from class org.infinispan.stream.impl.local.AbstractLocalCacheStream

close, createStream, isParallel, onClose, parallel, sequential, unordered

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.stream.DoubleStream

builder, concat, empty, generate, iterate, of, of, parallel, sequential

Methods inherited from interface java.util.stream.BaseStream

close, isParallel, onClose, unordered

Constructor Detail

LocalDoubleCacheStream

public LocalDoubleCacheStream(AbstractLocalCacheStream.StreamSupplier streamSupplier,
                              boolean parallel,
                              ComponentRegistry registry)

Parameters:

streamSupplier -

parallel -

registry -

Method Detail

filter

public DoubleStream filter(DoublePredicate predicate)

Specified by:

filter in interface DoubleStream

map

public DoubleStream map(DoubleUnaryOperator mapper)

Specified by:

map in interface DoubleStream

mapToObj

public <U> Stream<U> mapToObj(DoubleFunction<? extends U> mapper)

Specified by:

mapToObj in interface DoubleStream

mapToInt

public IntStream mapToInt(DoubleToIntFunction mapper)

Specified by:

mapToInt in interface DoubleStream

mapToLong

public LongStream mapToLong(DoubleToLongFunction mapper)

Specified by:

mapToLong in interface DoubleStream

flatMap

public DoubleStream flatMap(DoubleFunction<? extends DoubleStream> mapper)

Specified by:

flatMap in interface DoubleStream

distinct

public DoubleStream distinct()

Specified by:

distinct in interface DoubleStream

sorted

public DoubleStream sorted()

Specified by:

sorted in interface DoubleStream

peek

public DoubleStream peek(DoubleConsumer action)

Specified by:

peek in interface DoubleStream

limit

public DoubleStream limit(long maxSize)

Specified by:

limit in interface DoubleStream

skip

public DoubleStream skip(long n)

Specified by:

skip in interface DoubleStream

forEach

public void forEach(DoubleConsumer action)

Specified by:

forEach in interface DoubleStream

forEachOrdered

public void forEachOrdered(DoubleConsumer action)

Specified by:

forEachOrdered in interface DoubleStream

toArray

public double[] toArray()

Specified by:

toArray in interface DoubleStream

reduce

public double reduce(double identity,
                     DoubleBinaryOperator op)

Specified by:

reduce in interface DoubleStream

reduce

public OptionalDouble reduce(DoubleBinaryOperator op)

Specified by:

reduce in interface DoubleStream

collect

public <R> R collect(Supplier<R> supplier,
                     ObjDoubleConsumer<R> accumulator,
                     BiConsumer<R,R> combiner)

Specified by:

collect in interface DoubleStream

sum

public double sum()

Specified by:

sum in interface DoubleStream

min

public OptionalDouble min()

Specified by:

min in interface DoubleStream

max

public OptionalDouble max()

Specified by:

max in interface DoubleStream

count

public long count()

Specified by:

count in interface DoubleStream

average

public OptionalDouble average()

Specified by:

average in interface DoubleStream

summaryStatistics

public DoubleSummaryStatistics summaryStatistics()

Specified by:

summaryStatistics in interface DoubleStream

anyMatch

public boolean anyMatch(DoublePredicate predicate)

Specified by:

anyMatch in interface DoubleStream

allMatch

public boolean allMatch(DoublePredicate predicate)

Specified by:

allMatch in interface DoubleStream

noneMatch

public boolean noneMatch(DoublePredicate predicate)

Specified by:

noneMatch in interface DoubleStream

findFirst

public OptionalDouble findFirst()

Specified by:

findFirst in interface DoubleStream

findAny

public OptionalDouble findAny()

Specified by:

findAny in interface DoubleStream

boxed

public Stream<Double> boxed()

Specified by:

boxed in interface DoubleStream

iterator

public PrimitiveIterator.OfDouble iterator()

Specified by:

iterator in interface BaseStream<Double,DoubleStream>

Specified by:

iterator in interface DoubleStream

spliterator

public Spliterator.OfDouble spliterator()

Specified by:

spliterator in interface BaseStream<Double,DoubleStream>

Specified by:

spliterator in interface DoubleStream