dev.jeka.core.api.function

Class JkStreamDecorator<T>

java.lang.Object

dev.jeka.core.api.function.JkStreamDecorator<T>

Type Parameters:

T - the type of the stream elements

All Implemented Interfaces:

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

Direct Known Subclasses:

JkAbstractPathTree.JkPathTreeStream

public abstract class JkStreamDecorator<T>
extends java.lang.Object
implements java.util.stream.Stream<T>

A generic abstract class that decorates a Stream.

Nested Class Summary

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

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

Constructor Summary

Constructors

Constructor and Description
JkStreamDecorator(java.util.stream.Stream<T> stream)

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.stream.Stream

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

Constructor Detail

JkStreamDecorator

public JkStreamDecorator(java.util.stream.Stream<T> stream)

Method Detail

filter

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

Specified by:

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

map

public <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

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

Specified by:

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

mapToLong

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

Specified by:

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

mapToDouble

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

Specified by:

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

flatMap

public <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

public 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

public 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

public 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

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

Specified by:

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

sorted

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

Specified by:

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

sorted

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

Specified by:

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

peek

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

Specified by:

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

limit

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

Specified by:

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

skip

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

Specified by:

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

forEach

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

Specified by:

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

forEachOrdered

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

Specified by:

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

toArray

public java.lang.Object[] toArray()

Specified by:

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

toArray

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

Specified by:

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

reduce

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

Specified by:

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

reduce

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

Specified by:

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

reduce

public <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

public <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

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

Specified by:

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

min

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

Specified by:

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

max

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

Specified by:

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

count

public long count()

Specified by:

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

anyMatch

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

Specified by:

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

allMatch

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

Specified by:

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

noneMatch

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

Specified by:

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

findFirst

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

Specified by:

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

findAny

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

Specified by:

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

iterator

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

Specified by:

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

spliterator

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

Specified by:

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

parallel

public java.util.stream.Stream<T> parallel()

Specified by:

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

sequential

public java.util.stream.Stream<T> sequential()

Specified by:

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

isParallel

public boolean isParallel()

Specified by:

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

unordered

public java.util.stream.Stream<T> unordered()

Specified by:

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

onClose

public java.util.stream.Stream<T> onClose(java.lang.Runnable closeHandler)

Specified by:

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

close

public 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>>