org.infinispan.stream.impl.local

Class LocalIntCacheStream

java.lang.Object

org.infinispan.stream.impl.local.AbstractLocalCacheStream<Integer,IntStream>

org.infinispan.stream.impl.local.LocalIntCacheStream

All Implemented Interfaces:

AutoCloseable, BaseStream<Integer,IntStream>, IntStream

public class LocalIntCacheStream
extends AbstractLocalCacheStream<Integer,IntStream>
implements IntStream

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

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

Method Summary

Modifier and Type	Method and Description
boolean	allMatch(IntPredicate predicate)
boolean	anyMatch(IntPredicate predicate)
DoubleStream	asDoubleStream()
LongStream	asLongStream()
OptionalDouble	average()
Stream<Integer>	boxed()
<R> R	collect(Supplier<R> supplier, ObjIntConsumer<R> accumulator, BiConsumer<R,R> combiner)
long	count()
IntStream	distinct()
IntStream	filter(IntPredicate predicate)
OptionalInt	findAny()
OptionalInt	findFirst()
IntStream	flatMap(IntFunction<? extends IntStream> mapper)
void	forEach(IntConsumer action)
void	forEachOrdered(IntConsumer action)
PrimitiveIterator.OfInt	iterator()
IntStream	limit(long maxSize)
IntStream	map(IntUnaryOperator mapper)
DoubleStream	mapToDouble(IntToDoubleFunction mapper)
LongStream	mapToLong(IntToLongFunction mapper)
<U> Stream<U>	mapToObj(IntFunction<? extends U> mapper)
OptionalInt	max()
OptionalInt	min()
boolean	noneMatch(IntPredicate predicate)
IntStream	peek(IntConsumer action)
OptionalInt	reduce(IntBinaryOperator op)
int	reduce(int identity, IntBinaryOperator op)
IntStream	skip(long n)
IntStream	sorted()
Spliterator.OfInt	spliterator()
int	sum()
IntSummaryStatistics	summaryStatistics()
int[]	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.IntStream

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

LocalIntCacheStream

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

Parameters:

streamSupplier -

parallel -

registry -

Method Detail

filter

public IntStream filter(IntPredicate predicate)

Specified by:

filter in interface IntStream

map

public IntStream map(IntUnaryOperator mapper)

Specified by:

map in interface IntStream

mapToObj

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

Specified by:

mapToObj in interface IntStream

mapToLong

public LongStream mapToLong(IntToLongFunction mapper)

Specified by:

mapToLong in interface IntStream

mapToDouble

public DoubleStream mapToDouble(IntToDoubleFunction mapper)

Specified by:

mapToDouble in interface IntStream

flatMap

public IntStream flatMap(IntFunction<? extends IntStream> mapper)

Specified by:

flatMap in interface IntStream

distinct

public IntStream distinct()

Specified by:

distinct in interface IntStream

sorted

public IntStream sorted()

Specified by:

sorted in interface IntStream

peek

public IntStream peek(IntConsumer action)

Specified by:

peek in interface IntStream

limit

public IntStream limit(long maxSize)

Specified by:

limit in interface IntStream

skip

public IntStream skip(long n)

Specified by:

skip in interface IntStream

forEach

public void forEach(IntConsumer action)

Specified by:

forEach in interface IntStream

forEachOrdered

public void forEachOrdered(IntConsumer action)

Specified by:

forEachOrdered in interface IntStream

toArray

public int[] toArray()

Specified by:

toArray in interface IntStream

reduce

public int reduce(int identity,
                  IntBinaryOperator op)

Specified by:

reduce in interface IntStream

reduce

public OptionalInt reduce(IntBinaryOperator op)

Specified by:

reduce in interface IntStream

collect

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

Specified by:

collect in interface IntStream

sum

public int sum()

Specified by:

sum in interface IntStream

min

public OptionalInt min()

Specified by:

min in interface IntStream

max

public OptionalInt max()

Specified by:

max in interface IntStream

count

public long count()

Specified by:

count in interface IntStream

average

public OptionalDouble average()

Specified by:

average in interface IntStream

summaryStatistics

public IntSummaryStatistics summaryStatistics()

Specified by:

summaryStatistics in interface IntStream

anyMatch

public boolean anyMatch(IntPredicate predicate)

Specified by:

anyMatch in interface IntStream

allMatch

public boolean allMatch(IntPredicate predicate)

Specified by:

allMatch in interface IntStream

noneMatch

public boolean noneMatch(IntPredicate predicate)

Specified by:

noneMatch in interface IntStream

findFirst

public OptionalInt findFirst()

Specified by:

findFirst in interface IntStream

findAny

public OptionalInt findAny()

Specified by:

findAny in interface IntStream

asLongStream

public LongStream asLongStream()

Specified by:

asLongStream in interface IntStream

asDoubleStream

public DoubleStream asDoubleStream()

Specified by:

asDoubleStream in interface IntStream

boxed

public Stream<Integer> boxed()

Specified by:

boxed in interface IntStream

iterator

public PrimitiveIterator.OfInt iterator()

Specified by:

iterator in interface BaseStream<Integer,IntStream>

Specified by:

iterator in interface IntStream

spliterator

public Spliterator.OfInt spliterator()

Specified by:

spliterator in interface BaseStream<Integer,IntStream>

Specified by:

spliterator in interface IntStream