org.infinispan.stream.impl.local

Class LocalLongCacheStream

java.lang.Object

org.infinispan.stream.impl.local.AbstractLocalCacheStream<Long,LongStream>

org.infinispan.stream.impl.local.LocalLongCacheStream

All Implemented Interfaces:

AutoCloseable, BaseStream<Long,LongStream>, LongStream

public class LocalLongCacheStream
extends AbstractLocalCacheStream<Long,LongStream>
implements LongStream

LongStream 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.LongStream

LongStream.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
LocalLongCacheStream(AbstractLocalCacheStream.StreamSupplier streamSupplier, boolean parallel, ComponentRegistry registry)

Method Summary

Modifier and Type	Method and Description
boolean	allMatch(LongPredicate predicate)
boolean	anyMatch(LongPredicate predicate)
DoubleStream	asDoubleStream()
OptionalDouble	average()
Stream<Long>	boxed()
<R> R	collect(Supplier<R> supplier, ObjLongConsumer<R> accumulator, BiConsumer<R,R> combiner)
long	count()
LongStream	distinct()
LongStream	filter(LongPredicate predicate)
OptionalLong	findAny()
OptionalLong	findFirst()
LongStream	flatMap(LongFunction<? extends LongStream> mapper)
void	forEach(LongConsumer action)
void	forEachOrdered(LongConsumer action)
PrimitiveIterator.OfLong	iterator()
LongStream	limit(long maxSize)
LongStream	map(LongUnaryOperator mapper)
DoubleStream	mapToDouble(LongToDoubleFunction mapper)
IntStream	mapToInt(LongToIntFunction mapper)
<U> Stream<U>	mapToObj(LongFunction<? extends U> mapper)
OptionalLong	max()
OptionalLong	min()
boolean	noneMatch(LongPredicate predicate)
LongStream	peek(LongConsumer action)
OptionalLong	reduce(LongBinaryOperator op)
long	reduce(long identity, LongBinaryOperator op)
LongStream	skip(long n)
LongStream	sorted()
Spliterator.OfLong	spliterator()
long	sum()
LongSummaryStatistics	summaryStatistics()
long[]	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.LongStream

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

Methods inherited from interface java.util.stream.BaseStream

close, isParallel, onClose, unordered

Constructor Detail

LocalLongCacheStream

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

Parameters:

streamSupplier -

parallel -

registry -

Method Detail

filter

public LongStream filter(LongPredicate predicate)

Specified by:

filter in interface LongStream

map

public LongStream map(LongUnaryOperator mapper)

Specified by:

map in interface LongStream

mapToObj

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

Specified by:

mapToObj in interface LongStream

mapToInt

public IntStream mapToInt(LongToIntFunction mapper)

Specified by:

mapToInt in interface LongStream

mapToDouble

public DoubleStream mapToDouble(LongToDoubleFunction mapper)

Specified by:

mapToDouble in interface LongStream

flatMap

public LongStream flatMap(LongFunction<? extends LongStream> mapper)

Specified by:

flatMap in interface LongStream

distinct

public LongStream distinct()

Specified by:

distinct in interface LongStream

sorted

public LongStream sorted()

Specified by:

sorted in interface LongStream

peek

public LongStream peek(LongConsumer action)

Specified by:

peek in interface LongStream

limit

public LongStream limit(long maxSize)

Specified by:

limit in interface LongStream

skip

public LongStream skip(long n)

Specified by:

skip in interface LongStream

forEach

public void forEach(LongConsumer action)

Specified by:

forEach in interface LongStream

forEachOrdered

public void forEachOrdered(LongConsumer action)

Specified by:

forEachOrdered in interface LongStream

toArray

public long[] toArray()

Specified by:

toArray in interface LongStream

reduce

public long reduce(long identity,
                   LongBinaryOperator op)

Specified by:

reduce in interface LongStream

reduce

public OptionalLong reduce(LongBinaryOperator op)

Specified by:

reduce in interface LongStream

collect

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

Specified by:

collect in interface LongStream

sum

public long sum()

Specified by:

sum in interface LongStream

min

public OptionalLong min()

Specified by:

min in interface LongStream

max

public OptionalLong max()

Specified by:

max in interface LongStream

count

public long count()

Specified by:

count in interface LongStream

average

public OptionalDouble average()

Specified by:

average in interface LongStream

summaryStatistics

public LongSummaryStatistics summaryStatistics()

Specified by:

summaryStatistics in interface LongStream

anyMatch

public boolean anyMatch(LongPredicate predicate)

Specified by:

anyMatch in interface LongStream

allMatch

public boolean allMatch(LongPredicate predicate)

Specified by:

allMatch in interface LongStream

noneMatch

public boolean noneMatch(LongPredicate predicate)

Specified by:

noneMatch in interface LongStream

findFirst

public OptionalLong findFirst()

Specified by:

findFirst in interface LongStream

findAny

public OptionalLong findAny()

Specified by:

findAny in interface LongStream

asDoubleStream

public DoubleStream asDoubleStream()

Specified by:

asDoubleStream in interface LongStream

boxed

public Stream<Long> boxed()

Specified by:

boxed in interface LongStream

iterator

public PrimitiveIterator.OfLong iterator()

Specified by:

iterator in interface BaseStream<Long,LongStream>

Specified by:

iterator in interface LongStream

spliterator

public Spliterator.OfLong spliterator()

Specified by:

spliterator in interface BaseStream<Long,LongStream>

Specified by:

spliterator in interface LongStream