uk.co.strangeskies.collection.stream

Interface StreamDecorator<T>

Type Parameters:

T - the type of the elements of the stream

All Superinterfaces:

java.lang.AutoCloseable, java.util.stream.BaseStream<T,java.util.stream.Stream<T>>, BaseStreamDecorator<T,java.util.stream.Stream<T>>, java.util.stream.Stream<T>

All Known Implementing Classes:

ResourceStream.ReferenceResourceStream

public interface StreamDecorator<T>
extends BaseStreamDecorator<T,java.util.stream.Stream<T>>, java.util.stream.Stream<T>

A decorator for a Stream which wraps intermediate and terminal operations such that they can be easily extended.

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.stream.Stream

java.util.stream.Stream.Builder<T>

Method Summary

Modifier and Type	Method and Description
default boolean	allMatch(java.util.function.Predicate<? super T> predicate)
default boolean	anyMatch(java.util.function.Predicate<? super T> predicate)
default <R,A> R	collect(java.util.stream.Collector<? super T,A,R> collector)
default <R> R	collect(java.util.function.Supplier<R> supplier, java.util.function.BiConsumer<R,? super T> accumulator, java.util.function.BiConsumer<R,R> combiner)
default long	count()
default java.util.stream.Stream<T>	decorateIntermediate(java.util.function.Function<? super java.util.stream.Stream<T>,java.util.stream.Stream<T>> transformation)
default java.util.stream.Stream<T>	distinct()
default java.util.stream.Stream<T>	filter(java.util.function.Predicate<? super T> predicate)
default java.util.Optional<T>	findAny()
default java.util.Optional<T>	findFirst()
default <R> java.util.stream.Stream<R>	flatMap(java.util.function.Function<? super T,? extends java.util.stream.Stream<? extends R>> mapper)
default java.util.stream.DoubleStream	flatMapToDouble(java.util.function.Function<? super T,? extends java.util.stream.DoubleStream> mapper)
default java.util.stream.IntStream	flatMapToInt(java.util.function.Function<? super T,? extends java.util.stream.IntStream> mapper)
default java.util.stream.LongStream	flatMapToLong(java.util.function.Function<? super T,? extends java.util.stream.LongStream> mapper)
default void	forEach(java.util.function.Consumer<? super T> action)
default void	forEachOrdered(java.util.function.Consumer<? super T> action)
java.util.stream.Stream<T>	getComponent()
default java.util.stream.Stream<T>	limit(long maxSize)
default <R> java.util.stream.Stream<R>	map(java.util.function.Function<? super T,? extends R> mapper)
default java.util.stream.DoubleStream	mapToDouble(java.util.function.ToDoubleFunction<? super T> mapper)
default java.util.stream.IntStream	mapToInt(java.util.function.ToIntFunction<? super T> mapper)
default java.util.stream.LongStream	mapToLong(java.util.function.ToLongFunction<? super T> mapper)
default java.util.Optional<T>	max(java.util.Comparator<? super T> comparator)
default java.util.Optional<T>	min(java.util.Comparator<? super T> comparator)
default boolean	noneMatch(java.util.function.Predicate<? super T> predicate)
default java.util.stream.Stream<T>	peek(java.util.function.Consumer<? super T> action)
default java.util.Optional<T>	reduce(java.util.function.BinaryOperator<T> accumulator)
default T	reduce(T identity, java.util.function.BinaryOperator<T> accumulator)
default <U> U	reduce(U identity, java.util.function.BiFunction<U,? super T,U> accumulator, java.util.function.BinaryOperator<U> combiner)
default java.util.stream.Stream<T>	skip(long n)
default java.util.stream.Stream<T>	sorted()
default java.util.stream.Stream<T>	sorted(java.util.Comparator<? super T> comparator)
default java.lang.Object[]	toArray()
default <A> A[]	toArray(java.util.function.IntFunction<A[]> generator)

Methods inherited from interface uk.co.strangeskies.collection.stream.BaseStreamDecorator

close, decorateIntermediateDouble, decorateIntermediateInt, decorateIntermediateLong, decorateIntermediateReference, decorateTerminal, decorateVoidTerminal, isParallel, iterator, onClose, parallel, sequential, spliterator, unordered

Methods inherited from interface java.util.stream.Stream

builder, concat, empty, generate, iterate, of, of

Method Detail

getComponent

java.util.stream.Stream<T> getComponent()

Specified by:

getComponent in interface BaseStreamDecorator<T,java.util.stream.Stream<T>>

Returns:

the component reference

decorateIntermediate

default java.util.stream.Stream<T> decorateIntermediate(java.util.function.Function<? super java.util.stream.Stream<T>,java.util.stream.Stream<T>> transformation)

Specified by:

decorateIntermediate in interface BaseStreamDecorator<T,java.util.stream.Stream<T>>

Parameters:

transformation - the intermediate operation as a function on a stream

Returns:

a decorated instance of the result of application of the transformation to the component

filter

default java.util.stream.Stream<T> filter(java.util.function.Predicate<? super T> predicate)

Specified by:

filter in interface java.util.stream.Stream<T>

map

default <R> java.util.stream.Stream<R> map(java.util.function.Function<? super T,? extends R> mapper)

Specified by:

map in interface java.util.stream.Stream<T>

mapToInt

default java.util.stream.IntStream mapToInt(java.util.function.ToIntFunction<? super T> mapper)

Specified by:

mapToInt in interface java.util.stream.Stream<T>

mapToLong

default java.util.stream.LongStream mapToLong(java.util.function.ToLongFunction<? super T> mapper)

Specified by:

mapToLong in interface java.util.stream.Stream<T>

mapToDouble

default java.util.stream.DoubleStream mapToDouble(java.util.function.ToDoubleFunction<? super T> mapper)

Specified by:

mapToDouble in interface java.util.stream.Stream<T>

flatMap

default <R> java.util.stream.Stream<R> flatMap(java.util.function.Function<? super T,? extends java.util.stream.Stream<? extends R>> mapper)

Specified by:

flatMap in interface java.util.stream.Stream<T>

flatMapToInt

default java.util.stream.IntStream flatMapToInt(java.util.function.Function<? super T,? extends java.util.stream.IntStream> mapper)

Specified by:

flatMapToInt in interface java.util.stream.Stream<T>

flatMapToLong

default java.util.stream.LongStream flatMapToLong(java.util.function.Function<? super T,? extends java.util.stream.LongStream> mapper)

Specified by:

flatMapToLong in interface java.util.stream.Stream<T>

flatMapToDouble

default java.util.stream.DoubleStream flatMapToDouble(java.util.function.Function<? super T,? extends java.util.stream.DoubleStream> mapper)

Specified by:

flatMapToDouble in interface java.util.stream.Stream<T>

distinct

default java.util.stream.Stream<T> distinct()

Specified by:

distinct in interface java.util.stream.Stream<T>

sorted

default java.util.stream.Stream<T> sorted()

Specified by:

sorted in interface java.util.stream.Stream<T>

sorted

default java.util.stream.Stream<T> sorted(java.util.Comparator<? super T> comparator)

Specified by:

sorted in interface java.util.stream.Stream<T>

peek

default java.util.stream.Stream<T> peek(java.util.function.Consumer<? super T> action)

Specified by:

peek in interface java.util.stream.Stream<T>

limit

default java.util.stream.Stream<T> limit(long maxSize)

Specified by:

limit in interface java.util.stream.Stream<T>

skip

default java.util.stream.Stream<T> skip(long n)

Specified by:

skip in interface java.util.stream.Stream<T>

forEach

default void forEach(java.util.function.Consumer<? super T> action)

Specified by:

forEach in interface java.util.stream.Stream<T>

forEachOrdered

default void forEachOrdered(java.util.function.Consumer<? super T> action)

Specified by:

forEachOrdered in interface java.util.stream.Stream<T>

toArray

default java.lang.Object[] toArray()

Specified by:

toArray in interface java.util.stream.Stream<T>

toArray

default <A> A[] toArray(java.util.function.IntFunction<A[]> generator)

Specified by:

toArray in interface java.util.stream.Stream<T>

reduce

default T reduce(T identity,
                 java.util.function.BinaryOperator<T> accumulator)

Specified by:

reduce in interface java.util.stream.Stream<T>

reduce

default java.util.Optional<T> reduce(java.util.function.BinaryOperator<T> accumulator)

Specified by:

reduce in interface java.util.stream.Stream<T>

reduce

default <U> U reduce(U identity,
                     java.util.function.BiFunction<U,? super T,U> accumulator,
                     java.util.function.BinaryOperator<U> combiner)

Specified by:

reduce in interface java.util.stream.Stream<T>

collect

default <R> R collect(java.util.function.Supplier<R> supplier,
                      java.util.function.BiConsumer<R,? super T> accumulator,
                      java.util.function.BiConsumer<R,R> combiner)

Specified by:

collect in interface java.util.stream.Stream<T>

collect

default <R,A> R collect(java.util.stream.Collector<? super T,A,R> collector)

Specified by:

collect in interface java.util.stream.Stream<T>

min

default java.util.Optional<T> min(java.util.Comparator<? super T> comparator)

Specified by:

min in interface java.util.stream.Stream<T>

max

default java.util.Optional<T> max(java.util.Comparator<? super T> comparator)

Specified by:

max in interface java.util.stream.Stream<T>

count

default long count()

Specified by:

count in interface java.util.stream.Stream<T>

anyMatch

default boolean anyMatch(java.util.function.Predicate<? super T> predicate)

Specified by:

anyMatch in interface java.util.stream.Stream<T>

allMatch

default boolean allMatch(java.util.function.Predicate<? super T> predicate)

Specified by:

allMatch in interface java.util.stream.Stream<T>

noneMatch

default boolean noneMatch(java.util.function.Predicate<? super T> predicate)

Specified by:

noneMatch in interface java.util.stream.Stream<T>

findFirst

default java.util.Optional<T> findFirst()

Specified by:

findFirst in interface java.util.stream.Stream<T>

findAny

default java.util.Optional<T> findAny()

Specified by:

findAny in interface java.util.stream.Stream<T>