public abstract class WrappingStream<T> extends Object implements Stream<T>
Stream.Builder<T>
Constructor and Description |
---|
WrappingStream() |
Modifier and Type | Method and Description |
---|---|
boolean |
allMatch(Predicate<? super T> predicate) |
boolean |
anyMatch(Predicate<? super T> predicate) |
void |
close() |
<R,A> R |
collect(Collector<? super T,A,R> collector) |
<R> R |
collect(Supplier<R> supplier,
BiConsumer<R,? super T> accumulator,
BiConsumer<R,R> combiner) |
long |
count() |
Optional<T> |
findAny() |
Optional<T> |
findFirst() |
<R> Stream<R> |
flatMap(Function<? super T,? extends Stream<? extends R>> mapper) |
DoubleStream |
flatMapToDouble(Function<? super T,? extends DoubleStream> mapper) |
IntStream |
flatMapToInt(Function<? super T,? extends IntStream> mapper) |
LongStream |
flatMapToLong(Function<? super T,? extends LongStream> mapper) |
void |
forEach(Consumer<? super T> action) |
void |
forEachOrdered(Consumer<? super T> action) |
boolean |
isParallel() |
Iterator<T> |
iterator() |
<R> Stream<R> |
map(Function<? super T,? extends R> mapper) |
DoubleStream |
mapToDouble(ToDoubleFunction<? super T> mapper) |
IntStream |
mapToInt(ToIntFunction<? super T> mapper) |
LongStream |
mapToLong(ToLongFunction<? super T> mapper) |
Optional<T> |
max(Comparator<? super T> comparator) |
Optional<T> |
min(Comparator<? super T> comparator) |
boolean |
noneMatch(Predicate<? super T> predicate) |
Optional<T> |
reduce(BinaryOperator<T> accumulator) |
T |
reduce(T identity,
BinaryOperator<T> accumulator) |
<U> U |
reduce(U identity,
BiFunction<U,? super T,U> accumulator,
BinaryOperator<U> combiner) |
Spliterator<T> |
spliterator() |
Object[] |
toArray() |
<A> A[] |
toArray(IntFunction<A[]> generator) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
builder, concat, distinct, empty, filter, generate, iterate, limit, of, of, peek, skip, sorted, sorted
onClose, parallel, sequential, unordered
public WrappingStream()
public <R> R collect(Supplier<R> supplier, BiConsumer<R,? super T> accumulator, BiConsumer<R,R> combiner)
public DoubleStream flatMapToDouble(Function<? super T,? extends DoubleStream> mapper)
flatMapToDouble
in interface Stream<T>
public IntStream flatMapToInt(Function<? super T,? extends IntStream> mapper)
flatMapToInt
in interface Stream<T>
public LongStream flatMapToLong(Function<? super T,? extends LongStream> mapper)
flatMapToLong
in interface Stream<T>
public void forEachOrdered(Consumer<? super T> action)
forEachOrdered
in interface Stream<T>
public DoubleStream mapToDouble(ToDoubleFunction<? super T> mapper)
mapToDouble
in interface Stream<T>
public IntStream mapToInt(ToIntFunction<? super T> mapper)
public LongStream mapToLong(ToLongFunction<? super T> mapper)
public Optional<T> max(Comparator<? super T> comparator)
public Optional<T> min(Comparator<? super T> comparator)
public Optional<T> reduce(BinaryOperator<T> accumulator)
public T reduce(T identity, BinaryOperator<T> accumulator)
public <U> U reduce(U identity, BiFunction<U,? super T,U> accumulator, BinaryOperator<U> combiner)
public <A> A[] toArray(IntFunction<A[]> generator)
public void close()
close
in interface AutoCloseable
close
in interface BaseStream<T,Stream<T>>
public boolean isParallel()
isParallel
in interface BaseStream<T,Stream<T>>
public Spliterator<T> spliterator()
spliterator
in interface BaseStream<T,Stream<T>>
Copyright © 2013–2017 DuraSpace, Inc.. All rights reserved.