public class LocalIntCacheStream extends AbstractLocalCacheStream<Integer,IntStream> implements IntStream
AbstractLocalCacheStream.StreamSupplier<R>
IntStream.Builder
intermediateOperations, keysToFilter, log, onCloseRunnables, parallel, registry, segmentsToFilter, streamSupplier
Constructor and Description |
---|
LocalIntCacheStream(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, range, rangeClosed, sequential
close, isParallel, onClose, unordered
public LocalIntCacheStream(AbstractLocalCacheStream.StreamSupplier streamSupplier, boolean parallel, ComponentRegistry registry)
streamSupplier
- parallel
- registry
- public IntStream filter(IntPredicate predicate)
public IntStream map(IntUnaryOperator mapper)
public <U> Stream<U> mapToObj(IntFunction<? extends U> mapper)
public LongStream mapToLong(IntToLongFunction mapper)
public DoubleStream mapToDouble(IntToDoubleFunction mapper)
mapToDouble
in interface IntStream
public IntStream flatMap(IntFunction<? extends IntStream> mapper)
public IntStream peek(IntConsumer action)
public void forEach(IntConsumer action)
public void forEachOrdered(IntConsumer action)
forEachOrdered
in interface IntStream
public int reduce(int identity, IntBinaryOperator op)
public OptionalInt reduce(IntBinaryOperator op)
public <R> R collect(Supplier<R> supplier, ObjIntConsumer<R> accumulator, BiConsumer<R,R> combiner)
public OptionalInt min()
public OptionalInt max()
public OptionalDouble average()
public IntSummaryStatistics summaryStatistics()
summaryStatistics
in interface IntStream
public boolean anyMatch(IntPredicate predicate)
public boolean allMatch(IntPredicate predicate)
public boolean noneMatch(IntPredicate predicate)
public OptionalInt findFirst()
public OptionalInt findAny()
public LongStream asLongStream()
asLongStream
in interface IntStream
public DoubleStream asDoubleStream()
asDoubleStream
in interface IntStream
public PrimitiveIterator.OfInt iterator()
public Spliterator.OfInt spliterator()
spliterator
in interface BaseStream<Integer,IntStream>
spliterator
in interface IntStream
Copyright © 2017 JBoss, a division of Red Hat. All rights reserved.