Index

A B C D E F G H I L M N O P R S T U W Z
All Classes and Interfaces|All Packages

A

allMatch(Predicate<? super T>) - Method in class org.streamer.Streamer

anyMatch(Predicate<? super T>) - Method in class org.streamer.Streamer

arrayToCollection(Class<? extends Collection>, T[]) - Static method in class org.streamer.StreamUtils

Copies an array into a new collection of the given type, instantiated reflectively.

arrayToCollection(Supplier<C>, T[]) - Static method in class org.streamer.StreamUtils

Copies an array into a new collection produced by the given factory.

asStream(Iterable<T>) - Static method in class org.streamer.StreamUtils

Wraps an Iterable in a sequential stream.

asStream(Enumeration<T>) - Static method in class org.streamer.StreamUtils

Wraps a legacy Enumeration in a sequential stream.

asStream(Iterator<T>) - Static method in class org.streamer.StreamUtils

Wraps an Iterator in a sequential stream.

B

batch(int) - Method in class org.streamer.Streamer

Groups consecutive elements into immutable lists of the given size.

batch(Stream<T>, int) - Static method in class org.streamer.StreamUtils

Groups consecutive elements into immutable lists of the given size.

C

close() - Method in class org.streamer.Streamer

collect(Supplier<R>, BiConsumer<R, ? super T>, BiConsumer<R, R>) - Method in class org.streamer.Streamer

collect(Collector<? super T, A, R>) - Method in class org.streamer.Streamer

comparing(Comparator<? super A>, Comparator<? super B>) - Static method in record class org.streamer.Pair

Returns a comparator that orders pairs by their first value, then by their second.

concat(Stream<? extends T>...) - Static method in class org.streamer.StreamUtils

Concatenates several streams into one.

concatWith(Stream<? extends T>) - Method in class org.streamer.Streamer

Appends another stream after this one.

count() - Method in class org.streamer.Streamer

D

distinct() - Method in class org.streamer.Streamer

distinctBy(Function<? super T, ?>) - Method in class org.streamer.Streamer

Keeps the first element for each distinct key.

distinctBy(Stream<T>, Function<? super T, ?>) - Static method in class org.streamer.StreamUtils

Keeps the first element for each distinct key, discarding later duplicates.

distinctByKey(Function<? super T, ?>) - Static method in class org.streamer.StreamUtils

Returns a stateful predicate that admits an element only the first time its key is seen.

dropWhile(Predicate<? super T>) - Method in class org.streamer.Streamer

E

empty() - Static method in class org.streamer.Streamer

Starts an empty stream.

equals(Object) - Method in record class org.streamer.Pair

Indicates whether some other object is "equal to" this one.

F

filter(Predicate<? super T>) - Method in class org.streamer.Streamer

filterByType(Class<R>) - Method in class org.streamer.Streamer

Keeps only the elements of the given type and casts them.

filterByType(Stream<?>, Class<T>) - Static method in class org.streamer.StreamUtils

Keeps only the elements that are instances of the given type and casts them.

filterNot(Predicate<? super T>) - Method in class org.streamer.Streamer

Keeps the elements that do not match the predicate.

filterNot(Stream<T>, Predicate<? super T>) - Static method in class org.streamer.StreamUtils

Keeps the elements that do not match the predicate.

findAny() - Method in class org.streamer.Streamer

findFirst() - Method in class org.streamer.Streamer

first() - Method in record class org.streamer.Pair

Returns the value of the first record component.

flatMap(Function<? super T, ? extends Stream<? extends R>>) - Method in class org.streamer.Streamer

flatMapToDouble(Function<? super T, ? extends DoubleStream>) - Method in class org.streamer.Streamer

flatMapToInt(Function<? super T, ? extends IntStream>) - Method in class org.streamer.Streamer

flatMapToLong(Function<? super T, ? extends LongStream>) - Method in class org.streamer.Streamer

flatMapToPair(Function<? super T, ? extends Stream<U>>) - Method in class org.streamer.Streamer

Expands each element into a stream and pairs every produced value with its source element.

flatMapToPair(Stream<T>, Function<? super T, ? extends Stream<U>>) - Static method in class org.streamer.StreamUtils

Expands each element into a stream and pairs every produced value with its source element.

fold(BiFunction<? super A, ? super B, ? extends R>) - Method in record class org.streamer.Pair

Collapses the pair into a single value.

forEach(Consumer<? super T>) - Method in class org.streamer.Streamer

forEachOrdered(Consumer<? super T>) - Method in class org.streamer.Streamer

from(Iterable<T>) - Static method in class org.streamer.Streamer

Starts a stream over an iterable.

from(Iterator<T>) - Static method in class org.streamer.Streamer

Starts a stream over an iterator.

fromEntry(Map.Entry<K, V>) - Static method in record class org.streamer.Pair

Creates a pair from a map entry.

G

groupAdjacent(BiPredicate<? super T, ? super T>) - Method in class org.streamer.Streamer

Groups runs of adjacent elements that belong together.

groupAdjacent(Stream<T>, BiPredicate<? super T, ? super T>) - Static method in class org.streamer.StreamUtils

Groups runs of adjacent elements that belong together.

groupAdjacentBy(Function<? super T, ? extends K>) - Method in class org.streamer.Streamer

Groups runs of adjacent elements that produce the same key.

groupAdjacentBy(Stream<T>, Function<? super T, ? extends K>) - Static method in class org.streamer.StreamUtils

Groups runs of adjacent elements that produce the same key.

H

hashCode() - Method in record class org.streamer.Pair

Returns a hash code value for this object.

I

interleave(Stream<? extends T>, Stream<? extends T>) - Static method in class org.streamer.StreamUtils

Alternates between two streams, taking one element from each in turn.

interleaveWith(Stream<? extends T>) - Method in class org.streamer.Streamer

Alternates between this stream and the other, taking one element from each in turn.

isParallel() - Method in class org.streamer.Streamer

iterator() - Method in class org.streamer.Streamer

L

limit(long) - Method in class org.streamer.Streamer

M

map(Function<? super T, ? extends R>) - Method in class org.streamer.Streamer

mapFirst(Function<? super A, ? extends R>) - Method in record class org.streamer.Pair

Applies a function to the first value and keeps the second one unchanged.

mapMulti(BiConsumer<? super T, ? super Consumer<R>>) - Method in class org.streamer.Streamer

mapMultiToDouble(BiConsumer<? super T, ? super DoubleConsumer>) - Method in class org.streamer.Streamer

mapMultiToInt(BiConsumer<? super T, ? super IntConsumer>) - Method in class org.streamer.Streamer

mapMultiToLong(BiConsumer<? super T, ? super LongConsumer>) - Method in class org.streamer.Streamer

mapSecond(Function<? super B, ? extends R>) - Method in record class org.streamer.Pair

Applies a function to the second value and keeps the first one unchanged.

mapToDouble(ToDoubleFunction<? super T>) - Method in class org.streamer.Streamer

mapToInt(ToIntFunction<? super T>) - Method in class org.streamer.Streamer

mapToLong(ToLongFunction<? super T>) - Method in class org.streamer.Streamer

max(Comparator<? super T>) - Method in class org.streamer.Streamer

mergeSorted(Stream<? extends T>, Stream<? extends T>, Comparator<? super T>) - Static method in class org.streamer.StreamUtils

Merges two streams that are already sorted, preserving the ordering.

mergeSortedWith(Stream<? extends T>, Comparator<? super T>) - Method in class org.streamer.Streamer

Merges this stream with another one, both already sorted by the given comparator.

min(Comparator<? super T>) - Method in class org.streamer.Streamer

minMax(Comparator<? super T>) - Static method in class org.streamer.MoreCollectors

Finds the smallest and the largest element in a single pass.

MoreCollectors - Class in org.streamer

Collectors that complement Collectors.

N

noneMatch(Predicate<? super T>) - Method in class org.streamer.Streamer

O

of(A, B) - Static method in record class org.streamer.Pair

Creates a pair of the two given values.

of(Stream<T>) - Static method in class org.streamer.Streamer

Wraps an existing stream.

of(T...) - Static method in class org.streamer.Streamer

Starts a stream over the given elements.

ofNullable(T) - Static method in class org.streamer.StreamUtils

Returns a single element stream, or an empty stream when the element is null.

onClose(Runnable) - Method in class org.streamer.Streamer

org.streamer - module org.streamer

Stream operators and collectors that fill the gaps in java.util.stream.

org.streamer - package org.streamer

Stream operators and collectors that fill the gaps in java.util.stream.

P

Pair<A,B> - Record Class in org.streamer

An immutable pair of two values.

Pair(A, B) - Constructor for record class org.streamer.Pair

Creates an instance of a Pair record class.

parallel() - Method in class org.streamer.Streamer

peek(Consumer<? super T>) - Method in class org.streamer.Streamer

pipe(Function<? super Stream<T>, ? extends Stream<R>>) - Method in class org.streamer.Streamer

Applies a function to the whole stream, keeping the chain fluent.

R

range(int, int) - Static method in class org.streamer.Streamer

Starts a stream over [startInclusive, endExclusive).

range(int, int) - Static method in class org.streamer.StreamUtils

Returns a stream of boxed integers over [startInclusive, endExclusive).

reduce(BinaryOperator<T>) - Method in class org.streamer.Streamer

reduce(T, BinaryOperator<T>) - Method in class org.streamer.Streamer

reduce(U, BiFunction<U, ? super T, U>, BinaryOperator<U>) - Method in class org.streamer.Streamer

S

scan(Stream<T>, R, BiFunction<? super R, ? super T, ? extends R>) - Static method in class org.streamer.StreamUtils

Emits the running result of folding the stream from left to right.

scan(R, BiFunction<? super R, ? super T, ? extends R>) - Method in class org.streamer.Streamer

Emits the running result of folding the stream from left to right.

second() - Method in record class org.streamer.Pair

Returns the value of the second record component.

sequential() - Method in class org.streamer.Streamer

skip(long) - Method in class org.streamer.Streamer

sorted() - Method in class org.streamer.Streamer

sorted(Comparator<? super T>) - Method in class org.streamer.Streamer

splitBy(Predicate<? super T>) - Method in class org.streamer.Streamer

Cuts the stream into segments at the elements matching the delimiter.

splitBy(Stream<T>, Predicate<? super T>) - Static method in class org.streamer.StreamUtils

Cuts the stream into segments at the elements matching the delimiter, dropping the delimiters themselves.

spliterator() - Method in class org.streamer.Streamer

Streamer<T> - Class in org.streamer

A Stream that also carries the operators of StreamUtils.

StreamUtils - Class in org.streamer

Stream operators that the JDK does not ship.

swap() - Method in record class org.streamer.Pair

Returns a pair with the two values exchanged.

T

takeUntil(Predicate<? super T>) - Method in class org.streamer.Streamer

Takes elements up to and including the first one matching the predicate.

takeUntil(Stream<T>, Predicate<? super T>) - Static method in class org.streamer.StreamUtils

Takes elements up to and including the first one matching the predicate.

takeWhile(Predicate<? super T>) - Method in class org.streamer.Streamer

toArray() - Method in class org.streamer.Streamer

toArray(IntFunction<A[]>) - Method in class org.streamer.Streamer

toEntry() - Method in record class org.streamer.Pair

Converts the pair into an immutable map entry.

toFrequencyMap() - Static method in class org.streamer.MoreCollectors

Counts how many times each element occurs.

toLinkedMap(Function<? super T, ? extends K>, Function<? super T, ? extends V>) - Static method in class org.streamer.MoreCollectors

Collects into a LinkedHashMap, preserving encounter order and rejecting duplicates.

toList() - Method in class org.streamer.Streamer

toString() - Method in record class org.streamer.Pair

Returns a string representation of this record class.

U

unique() - Static method in class org.streamer.MoreCollectors

Collects distinct elements into a list, keeping the order in which they first appeared.

unordered() - Method in class org.streamer.Streamer

unwrap() - Method in class org.streamer.Streamer

Returns the wrapped stream.

W

windowed(int) - Method in class org.streamer.Streamer

Emits every sliding window of the given size, advancing one element at a time.

windowed(int, int) - Method in class org.streamer.Streamer

Emits sliding windows of the given size, advancing by step elements.

windowed(Stream<T>, int) - Static method in class org.streamer.StreamUtils

Emits every sliding window of the given size, advancing one element at a time.

windowed(Stream<T>, int, int) - Static method in class org.streamer.StreamUtils

Emits sliding windows of the given size, advancing by step elements.

Z

zip(Stream<A>, Stream<B>) - Static method in class org.streamer.StreamUtils

Pairs up two streams element by element.

zip(Stream<A>, Stream<B>, BiFunction<? super A, ? super B, ? extends R>) - Static method in class org.streamer.StreamUtils

Pairs up two streams element by element and combines each pair.

zip(Stream<U>) - Method in class org.streamer.Streamer

Pairs each element with the element at the same position of the other stream.

zip(Stream<U>, BiFunction<? super T, ? super U, ? extends R>) - Method in class org.streamer.Streamer

Pairs each element with the element at the same position of the other stream and combines the two.

zipWithIndex() - Method in class org.streamer.Streamer

Pairs each element with its zero based position.

zipWithIndex(Stream<T>) - Static method in class org.streamer.StreamUtils

Pairs each element with its zero based position.

A B C D E F G H I L M N O P R S T U W Z
All Classes and Interfaces|All Packages