uk.co.strangeskies.collection.stream

Interface SelfStreamDecorator<T,S extends SelfStreamDecorator<T,S>>

Type Parameters:

T - the type of the elements of the stream

S - the final implementing class

All Superinterfaces:

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

public interface SelfStreamDecorator<T,S extends SelfStreamDecorator<T,S>>
extends java.util.stream.Stream<T>, Self<S>

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 void	close()
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()
S	decorateIntermediate(java.util.function.Function<? super java.util.stream.Stream<T>,java.util.stream.Stream<T>> transformation)
default S	distinct()
default S	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 boolean	isParallel()
default java.util.Iterator<T>	iterator()
default S	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 S	onClose(java.lang.Runnable closeHandler)
default S	parallel()
default S	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 S	sequential()
default S	skip(long n)
default S	sorted()
default S	sorted(java.util.Comparator<? super T> comparator)
default java.util.Spliterator<T>	spliterator()
default java.lang.Object[]	toArray()
default <A> A[]	toArray(java.util.function.IntFunction<A[]> generator)
default S	unordered()

Methods inherited from interface java.util.stream.Stream

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

Methods inherited from interface uk.co.strangeskies.utility.Self

getThis

Method Detail

getComponent

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

decorateIntermediate

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

filter

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

Specified by:

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

iterator

default java.util.Iterator<T> iterator()

Specified by:

iterator in interface java.util.stream.BaseStream<T,java.util.stream.Stream<T>>

spliterator

default java.util.Spliterator<T> spliterator()

Specified by:

spliterator in interface java.util.stream.BaseStream<T,java.util.stream.Stream<T>>

isParallel

default boolean isParallel()

Specified by:

isParallel in interface java.util.stream.BaseStream<T,java.util.stream.Stream<T>>

sequential

default S sequential()

Specified by:

sequential in interface java.util.stream.BaseStream<T,java.util.stream.Stream<T>>

parallel

default S parallel()

Specified by:

parallel in interface java.util.stream.BaseStream<T,java.util.stream.Stream<T>>

unordered

default S unordered()

Specified by:

unordered in interface java.util.stream.BaseStream<T,java.util.stream.Stream<T>>

onClose

default S onClose(java.lang.Runnable closeHandler)

Specified by:

onClose in interface java.util.stream.BaseStream<T,java.util.stream.Stream<T>>

close

default void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.util.stream.BaseStream<T,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 S distinct()

Specified by:

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

sorted

default S sorted()

Specified by:

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

sorted

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

Specified by:

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

peek

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

Specified by:

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

limit

default S limit(long maxSize)

Specified by:

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

skip

default S 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>