Interface Stream<T>

All Superinterfaces:

AutoCloseable, BaseStream<T, Stream<T>>

public interface Stream<T>
extends BaseStream<T, Stream<T>>

A stream here is sequential and lazy: each stage pulls one element at a time from the one before it, and only when a terminal operation asks. So an infinite iterate or generate behind a limit ends, findFirst and the anyMatch family stop at the element that decides them, and the side effects of peek happen element by element, in encounter order.

What is not here: spliterators, and with them parallel evaluation. parallel() answers the stream it was called on.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	Stream.Builder<T>	java.util.stream.Stream.Builder: collects elements, then answers them as a stream, once.

Method Summary

Modifier and Type	Method	Description
boolean	allMatch(Predicate<? super T> predicate)
boolean	anyMatch(Predicate<? super T> predicate)
static <T> Stream.Builder<T>	builder()
<R> R	collect(Supplier<R> supplier, BiConsumer<R, ? super T> accumulator, BiConsumer<R,R> combiner)
<R,A> R	collect(Collector<? super T, A, R> collector)
static <T> Stream<T>	concat(Stream<? extends T> a, Stream<? extends T> b)
long	count()
Stream<T>	distinct()
Stream<T>	dropWhile(Predicate<? super T> predicate)
static <T> Stream<T>	empty()
Stream<T>	filter(Predicate<? super T> predicate)
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)
static <T> Stream<T>	generate(Supplier<? extends T> s)
static <T> Stream<T>	iterate(T seed, Predicate<? super T> hasNext, UnaryOperator<T> next)
static <T> Stream<T>	iterate(T seed, UnaryOperator<T> f)
Stream<T>	limit(long maxSize)
<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)
static <T> Stream<T>	of(T t)
static <T> Stream<T>	of(T... values)
static <T> Stream<T>	ofNullable(T t)
Stream<T>	peek(Consumer<? super T> action)
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)
Stream<T>	skip(long n)
Stream<T>	sorted()
Stream<T>	sorted(Comparator<? super T> comparator)
Stream<T>	takeWhile(Predicate<? super T> predicate)
Object[]	toArray()
<A> A[]	toArray(IntFunction<A[]> generator)
default List<T>	toList()	An unmodifiable list of the elements, which may be null.

Methods inherited from interface BaseStream

close, isParallel, iterator, onClose, parallel, sequential, unordered

Method Details

filter

Stream<T> filter(Predicate<? super T> predicate)

map

<R> Stream<R> map(Function<? super T, ? extends R> mapper)

mapToInt

IntStream mapToInt(ToIntFunction<? super T> mapper)

mapToLong

LongStream mapToLong(ToLongFunction<? super T> mapper)

mapToDouble

DoubleStream mapToDouble(ToDoubleFunction<? super T> mapper)

flatMap

<R> Stream<R> flatMap(Function<? super T, ? extends Stream<? extends R>> mapper)

flatMapToInt

IntStream flatMapToInt(Function<? super T, ? extends IntStream> mapper)

flatMapToLong

LongStream flatMapToLong(Function<? super T, ? extends LongStream> mapper)

flatMapToDouble

DoubleStream flatMapToDouble(Function<? super T, ? extends DoubleStream> mapper)

distinct

Stream<T> distinct()

sorted

Stream<T> sorted()

sorted

Stream<T> sorted(Comparator<? super T> comparator)

peek

Stream<T> peek(Consumer<? super T> action)

limit

Stream<T> limit(long maxSize)

skip

Stream<T> skip(long n)

takeWhile

Stream<T> takeWhile(Predicate<? super T> predicate)

dropWhile

Stream<T> dropWhile(Predicate<? super T> predicate)

forEach

void forEach(Consumer<? super T> action)

forEachOrdered

void forEachOrdered(Consumer<? super T> action)

toArray

Object[] toArray()

toArray

<A> A[] toArray(IntFunction<A[]> generator)

reduce

T reduce(T identity,
 BinaryOperator<T> accumulator)

reduce

Optional<T> reduce(BinaryOperator<T> accumulator)

reduce

<U> U reduce(U identity,
 BiFunction<U, ? super T, U> accumulator,
 BinaryOperator<U> combiner)

collect

<R> R collect(Supplier<R> supplier,
 BiConsumer<R, ? super T> accumulator,
 BiConsumer<R,R> combiner)

collect

<R,A> R collect(Collector<? super T, A, R> collector)

toList

default List<T> toList()

An unmodifiable list of the elements, which may be null.

min

Optional<T> min(Comparator<? super T> comparator)

max

Optional<T> max(Comparator<? super T> comparator)

count

long count()

anyMatch

boolean anyMatch(Predicate<? super T> predicate)

allMatch

boolean allMatch(Predicate<? super T> predicate)

noneMatch

boolean noneMatch(Predicate<? super T> predicate)

findFirst

Optional<T> findFirst()

findAny

Optional<T> findAny()

builder

static <T> Stream.Builder<T> builder()

empty

static <T> Stream<T> empty()

of

static <T> Stream<T> of(T t)

ofNullable

static <T> Stream<T> ofNullable(T t)

of

@SafeVarargs
static <T> Stream<T> of(T... values)

iterate

static <T> Stream<T> iterate(T seed,
 UnaryOperator<T> f)

iterate

static <T> Stream<T> iterate(T seed,
 Predicate<? super T> hasNext,
 UnaryOperator<T> next)

generate

static <T> Stream<T> generate(Supplier<? extends T> s)

concat

static <T> Stream<T> concat(Stream<? extends T> a,
 Stream<? extends T> b)