A C D E F G H I L M N O P R S T U W Z

A

aggregate(Stream<T>, BiPredicate<T, T>) - Static method in class com.codepoetics.protonpack.StreamUtils

Aggregates items from source stream into list of items while supplied predicate is true when evaluated on previous and current item.

aggregate(Stream<T>, int) - Static method in class com.codepoetics.protonpack.StreamUtils

Aggregates items from source stream into list of items with fixed size

aggregateOnListCondition(Stream<T>, BiPredicate<List<T>, T>) - Static method in class com.codepoetics.protonpack.StreamUtils

Aggregates items from source stream.

andThen(Function<? super R, ? extends V>) - Method in interface com.codepoetics.protonpack.functions.TriFunction

apply(A, B, C) - Method in interface com.codepoetics.protonpack.functions.TriFunction

C

collect() - Method in interface com.codepoetics.protonpack.maps.MapStream

Return a Map from the stream.

collect(BinaryOperator<V>) - Method in interface com.codepoetics.protonpack.maps.MapStream

Return a Map from the stream.

collect(Collector<T, ?, O>) - Method in interface com.codepoetics.protonpack.Streamable

Stream this streamable, and collect the stream with the supplied collector.

CollectorUtils - Class in com.codepoetics.protonpack.collectors

Utility class providing some collectors.

com.codepoetics.protonpack - package com.codepoetics.protonpack

com.codepoetics.protonpack.collectors - package com.codepoetics.protonpack.collectors

com.codepoetics.protonpack.functions - package com.codepoetics.protonpack.functions

com.codepoetics.protonpack.maps - package com.codepoetics.protonpack.maps

com.codepoetics.protonpack.selectors - package com.codepoetics.protonpack.selectors

concat(Streamable<T>) - Method in interface com.codepoetics.protonpack.Streamable

Concatenate this streamable with another streamable.

D

distinct() - Method in interface com.codepoetics.protonpack.maps.MapStream

E

empty() - Static method in interface com.codepoetics.protonpack.Streamable

Gets an empty streamable.

equals(Object) - Method in class com.codepoetics.protonpack.Indexed

F

filter(Predicate<? super Map.Entry<K, V>>) - Method in interface com.codepoetics.protonpack.maps.MapStream

filter(Predicate<? super T>) - Method in interface com.codepoetics.protonpack.Streamable

Transform this streamable's streams with the supplied filter predicate.

flatMap(Function<? super T, Stream<? extends T2>>) - Method in interface com.codepoetics.protonpack.Streamable

Transform this streamable's streams with the supplied flatmap.

forEach(Consumer<T>) - Method in interface com.codepoetics.protonpack.Streamable

Stream this streamable, and call forEach on the resulting stream with the supplied action.

forEachOrdered(Consumer<T>) - Method in interface com.codepoetics.protonpack.Streamable

Stream this streamable, and call forEach on the resulting stream in order with the supplied action.

G

getIndex() - Method in class com.codepoetics.protonpack.Indexed

getMessage() - Method in exception com.codepoetics.protonpack.collectors.NonUniqueValueException

getValue() - Method in class com.codepoetics.protonpack.Indexed

groupRuns(Stream<T>) - Static method in class com.codepoetics.protonpack.StreamUtils

Constructs a stream that represents grouped run using the default comparator.

groupRuns(Stream<T>, Comparator<T>) - Static method in class com.codepoetics.protonpack.StreamUtils

Constructs a stream that represents grouped run using the default comparator.

H

hashCode() - Method in class com.codepoetics.protonpack.Indexed

I

index(long, T) - Static method in class com.codepoetics.protonpack.Indexed

Combine an index and a value into an indexed value.

Indexed<T> - Class in com.codepoetics.protonpack

A value combined with an index, indicating its position in an ordered sequence.

indices() - Static method in class com.codepoetics.protonpack.StreamUtils

Constructs an infinite (although in practice bounded by Long.MAX_VALUE) stream of longs 0, 1, 2, 3...

interleave(Function<T[], Integer>, Stream<T>...) - Static method in class com.codepoetics.protonpack.StreamUtils

Construct a stream which interleaves the supplied streams, picking items using the supplied selector function.

interleave(Function<T[], Integer>, List<Stream<T>>) - Static method in class com.codepoetics.protonpack.StreamUtils

Construct a stream which interleaves the supplied streams, picking items using the supplied selector function.

inverseMapping() - Method in interface com.codepoetics.protonpack.maps.MapStream

Return a MapStream from which the key and values are reversed.

L

limit(long) - Method in interface com.codepoetics.protonpack.maps.MapStream

limit(long) - Method in interface com.codepoetics.protonpack.Streamable

Transform this streamable's streams by limiting the number of elements they can contain.

M

map(Function<? super T, ? extends T2>) - Method in interface com.codepoetics.protonpack.Streamable

Transform this streamable's streams with the supplied map.

mapEntries(Function<? super K, ? extends K1>, Function<? super V, ? extends V1>) - Method in interface com.codepoetics.protonpack.maps.MapStream

Applies the mapping for each keys and values in the map.

mapKeys(Function<? super K, ? extends K1>) - Method in interface com.codepoetics.protonpack.maps.MapStream

Applies the mapping for each keys in the map.

MapStream<K,V> - Interface in com.codepoetics.protonpack.maps

A stream of Map.Entry<K, V>.

mapValues(Function<? super V, ? extends V1>) - Method in interface com.codepoetics.protonpack.maps.MapStream

Applies the mapping for each values in the map.

maxBy(Function<T, Y>) - Static method in class com.codepoetics.protonpack.collectors.CollectorUtils

Find the item for which the supplied projection returns the maximum value.

maxBy(Function<T, Y>, Comparator<Y>) - Static method in class com.codepoetics.protonpack.collectors.CollectorUtils

Find the item for which the supplied projection returns the maximum value (variant for non-naturally-comparable projected values).

merge(Supplier<O>, BiFunction<O, T, O>, Stream<T>...) - Static method in class com.codepoetics.protonpack.StreamUtils

Construct a stream which merges together values from the supplied streams, somewhat in the manner of the stream constructed by StreamUtils.zip(java.util.stream.Stream, java.util.stream.Stream, java.util.function.BiFunction), but for an arbitrary number of streams and using a merger to merge the values from multiple streams into an accumulator.

mergeKeys() - Method in interface com.codepoetics.protonpack.maps.MapStream

Merge keys of the Stream into a new Stream

mergeKeys(BinaryOperator<V>) - Method in interface com.codepoetics.protonpack.maps.MapStream

Merge keys of the Stream into a new Stream with the merge function provided

mergeToList(Stream<T>...) - Static method in class com.codepoetics.protonpack.StreamUtils

Construct a stream which merges together values from the supplied streams into lists of values, somewhat in the manner of the stream constructed by StreamUtils.zip(java.util.stream.Stream, java.util.stream.Stream, java.util.function.BiFunction), but for an arbitrary number of streams.

minBy(Function<T, Y>) - Static method in class com.codepoetics.protonpack.collectors.CollectorUtils

Find the item for which the supplied projection returns the minimum value.

minBy(Function<T, Y>, Comparator<Y>) - Static method in class com.codepoetics.protonpack.collectors.CollectorUtils

Find the item for which the supplied projection returns the minimum value (variant for non-naturally-comparable projected values).

N

NonUniqueValueException - Exception in com.codepoetics.protonpack.collectors

NonUniqueValueException(Object, Object) - Constructor for exception com.codepoetics.protonpack.collectors.NonUniqueValueException

O

of(Map<K, V>) - Static method in interface com.codepoetics.protonpack.maps.MapStream

Construct a MapStream<K, V> from the map

of(K, V) - Static method in interface com.codepoetics.protonpack.maps.MapStream

Construct a MapStream<K, V> from a single key-value pair

of(K, V, K, V) - Static method in interface com.codepoetics.protonpack.maps.MapStream

Construct a MapStream<K, V> from a multiple key-value pairs

of(K, V, K, V, K, V) - Static method in interface com.codepoetics.protonpack.maps.MapStream

Construct a MapStream<K, V> from a multiple key-value pairs

of(K, V, K, V, K, V, K, V) - Static method in interface com.codepoetics.protonpack.maps.MapStream

Construct a MapStream<K, V> from a multiple key-value pairs

of(K, V, K, V, K, V, K, V, K, V) - Static method in interface com.codepoetics.protonpack.maps.MapStream

Construct a MapStream<K, V> from a multiple key-value pairs

of(Supplier<Stream<T>>) - Static method in interface com.codepoetics.protonpack.Streamable

For converting method references to no-arg methods that return streams into streamable.

of(T...) - Static method in interface com.codepoetics.protonpack.Streamable

Create a streamable that produces streams over an array of items.

of(Collection<T>) - Static method in interface com.codepoetics.protonpack.Streamable

Create a streamable that produces streams over a collection of items.

of(Iterable<T>) - Static method in interface com.codepoetics.protonpack.Streamable

Create a streamable that produces streams over an iterable of items.

of(Optional<T>) - Static method in interface com.codepoetics.protonpack.Streamable

Create a streamable that produces streams of 0 or 1 elements over an optional value.

ofAll(Streamable<T>...) - Static method in interface com.codepoetics.protonpack.Streamable

Concatenate a series of streamables together.

ofMaps(Map<K, V>...) - Static method in interface com.codepoetics.protonpack.maps.MapStream

Construct a MapStream<K, V> from the map

onClose(Runnable) - Method in interface com.codepoetics.protonpack.maps.MapStream

P

parallel() - Method in interface com.codepoetics.protonpack.maps.MapStream

peek(Consumer<? super Map.Entry<K, V>>) - Method in interface com.codepoetics.protonpack.maps.MapStream

R

reject(Stream<T>, Predicate<? super T>) - Static method in class com.codepoetics.protonpack.StreamUtils

Filter with the condition negated.

roundRobin() - Static method in class com.codepoetics.protonpack.selectors.Selectors

S

Selector<T> - Interface in com.codepoetics.protonpack.selectors

Selectors - Class in com.codepoetics.protonpack.selectors

sequential() - Method in interface com.codepoetics.protonpack.maps.MapStream

skip(long) - Method in interface com.codepoetics.protonpack.maps.MapStream

skip(long) - Method in interface com.codepoetics.protonpack.Streamable

Transform this streamable's streams by skipping elements

skipUntil(Stream<T>, Predicate<T>) - Static method in class com.codepoetics.protonpack.StreamUtils

Construct a stream which skips values from the source stream for as long as they do not meet the supplied condition, then streams every remaining value as soon as the first value is found which does meet the condition.

skipWhile(Stream<T>, Predicate<T>) - Static method in class com.codepoetics.protonpack.StreamUtils

Construct a stream which skips values from the source stream for as long as they meet the supplied condition, then streams every remaining value as soon as the first value is found which does not meet the condition.

sorted() - Method in interface com.codepoetics.protonpack.maps.MapStream

sorted(Comparator<? super Map.Entry<K, V>>) - Method in interface com.codepoetics.protonpack.maps.MapStream

sorted(Comparator<? super T>) - Method in interface com.codepoetics.protonpack.Streamable

Transform this streamable's streams by sorting them.

stream() - Method in interface com.codepoetics.protonpack.Streamable

Synonym for "get"

stream(Optional<T>) - Static method in class com.codepoetics.protonpack.StreamUtils

Converts an Optional value to a stream of 0..1 values

stream(Iterable<T>) - Static method in class com.codepoetics.protonpack.StreamUtils

Converts an Iterable into a Stream.

Streamable<T> - Interface in com.codepoetics.protonpack

A source of Streams that can be repeatedly streamed.

StreamUtils - Class in com.codepoetics.protonpack

Utility class providing static methods for performing various operations on Streams.

T

takeMax() - Static method in class com.codepoetics.protonpack.selectors.Selectors

takeMax(Comparator<? super T>) - Static method in class com.codepoetics.protonpack.selectors.Selectors

takeMin() - Static method in class com.codepoetics.protonpack.selectors.Selectors

takeMin(Comparator<? super T>) - Static method in class com.codepoetics.protonpack.selectors.Selectors

takeUntil(Stream<T>, Predicate<T>) - Static method in class com.codepoetics.protonpack.StreamUtils

Construct a stream which takes values from the source stream until one of them meets the supplied condition, and then stops.

takeWhile(Stream<T>, Predicate<T>) - Static method in class com.codepoetics.protonpack.StreamUtils

Construct a stream which takes values from the source stream for as long as they meet the supplied condition, and stops as soon as a value is encountered which does not meet the condition.

toArray(IntFunction<T[]>) - Method in interface com.codepoetics.protonpack.Streamable

Stream this streamable, and collect the stream to an array.

toList() - Method in interface com.codepoetics.protonpack.Streamable

Stream this streamable, and collect the stream to a list.

toMap(Function<? super T, ? extends K>) - Method in interface com.codepoetics.protonpack.Streamable

Stream this streamable, and collect the stream to a map, extracting keys with the supplied index function.

toMap(Function<? super T, ? extends K>, Function<? super T, ? extends V>) - Method in interface com.codepoetics.protonpack.Streamable

Stream this streamable, and collect the stream to a map, extracting keys and values with the supplied functions.

toSet() - Method in interface com.codepoetics.protonpack.Streamable

Stream this streamable, and collect the stream to a set.

transform(Function<Stream<T>, Stream<T2>>) - Method in interface com.codepoetics.protonpack.Streamable

Create a streamable that transforms the streams produced by this streamable with a stream transformer.

TriFunction<A,B,C,R> - Interface in com.codepoetics.protonpack.functions

U

unfold(T, Function<T, Optional<T>>) - Static method in class com.codepoetics.protonpack.StreamUtils

Construct a stream which takes the seed value and applies the generator to create the next value, feeding each new value back into the generator to create subsequent values.

unique() - Static method in class com.codepoetics.protonpack.collectors.CollectorUtils

A collector that returns the single member of a stream (if present), or throws a NonUniqueValueException if more than one item is found.

unordered() - Method in interface com.codepoetics.protonpack.maps.MapStream

W

windowed(Stream<T>, int) - Static method in class com.codepoetics.protonpack.StreamUtils

Constructs a stream that is a windowed view of the source stream of the size window size with a default overlap of one item

windowed(Stream<T>, int, int) - Static method in class com.codepoetics.protonpack.StreamUtils

Constructs a windowed stream where each element is a list of the window size and the skip is the offset from the start of each window.

Z

zip(Stream<L>, Stream<R>, BiFunction<L, R, O>) - Static method in class com.codepoetics.protonpack.StreamUtils

Zip together the "left" and "right" streams until either runs out of values.

zip(Stream<L>, Stream<M>, Stream<R>, TriFunction<L, M, R, O>) - Static method in class com.codepoetics.protonpack.StreamUtils

Zip together the "left", "middle" and "right" streams until any stream runs out of values.

zipWithIndex(Stream<T>) - Static method in class com.codepoetics.protonpack.StreamUtils

Zip the source stream together with the stream of indices() to provide a stream of indexed values.

A C D E F G H I L M N O P R S T U W Z