Module org.tquadrat.foundation.base

Package org.tquadrat.foundation.stream

Class StreamAdapter<T>

java.lang.Object

org.tquadrat.foundation.stream.StreamAdapter<T>

Type Parameters:

T - The type of the stream's elements.

All Implemented Interfaces:

AutoCloseable, BaseStream<T,Stream<T>>, Stream<T>

@ClassVersion(sourceVersion="$Id: StreamAdapter.java 1060 2023-09-24 19:21:40Z tquadrat $")
@API(status=STABLE,
     since="0.0.7")
public class StreamAdapter<T>
extends Object
implements Stream<T>

This class allows to intercept the calls to the methods of Stream. The default implementations of the methods will just delegate to the wrapped stream.

Author:

Thomas Thrien (thomas.thrien@tquadrat.org)

Version:

$Id: StreamAdapter.java 1060 2023-09-24 19:21:40Z tquadrat $

Since:

0.0.7

UML Diagram

⁠

UML Diagram for "org.tquadrat.foundation.stream.StreamAdapter"

⁠

Nested Class Summary

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

Stream.Builder<T>

Field Summary

Fields

Modifier and Type	Field	Description
private final Stream<T>	m_Wrapped	The wrapped stream.

Constructor Summary

Constructors

Constructor	Description
StreamAdapter(Stream<T> wrapped)	Creates a new StreamAdapter instance.

Method Summary

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

mapMulti, mapMultiToDouble, mapMultiToInt, mapMultiToLong, toList

Field Details

m_Wrapped

private final Stream<T> m_Wrapped

The wrapped stream.

Constructor Details

StreamAdapter

public StreamAdapter(Stream<T> wrapped)

Creates a new StreamAdapter instance.

Parameters:

wrapped - The stream that is wrapped by this adapter.

Method Details

allMatch

@MountPoint
public boolean allMatch(Predicate<? super T> predicate)

Specified by:

allMatch in interface Stream<T>

anyMatch

@MountPoint
public boolean anyMatch(Predicate<? super T> predicate)

Specified by:

anyMatch in interface Stream<T>

close

@MountPoint
public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface BaseStream<T,Stream<T>>

collect

@MountPoint
public <R,
A> R collect(Collector<? super T,A,R> collector)

Specified by:

collect in interface Stream<T>

collect

@MountPoint
public <R> R collect(Supplier<R> supplier,
 BiConsumer<R,? super T> accumulator,
 BiConsumer<R,R> combiner)

Specified by:

collect in interface Stream<T>

count

@MountPoint
public long count()

Specified by:

count in interface Stream<T>

distinct

@MountPoint
public Stream<T> distinct()

Specified by:

distinct in interface Stream<T>

dropWhile

@MountPoint
public Stream<T> dropWhile(Predicate<? super T> predicate)

Specified by:

dropWhile in interface Stream<T>

filter

@MountPoint
public Stream<T> filter(Predicate<? super T> predicate)

Specified by:

filter in interface Stream<T>

findAny

@MountPoint
public Optional<T> findAny()

Specified by:

findAny in interface Stream<T>

findFirst

@MountPoint
public Optional<T> findFirst()

Specified by:

findFirst in interface Stream<T>

flatMap

@MountPoint
public <R> Stream<R> flatMap(Function<? super T,? extends Stream<? extends R>> mapper)

Specified by:

flatMap in interface Stream<T>

flatMapToDouble

@MountPoint
public DoubleStream flatMapToDouble(Function<? super T,? extends DoubleStream> mapper)

Specified by:

flatMapToDouble in interface Stream<T>

flatMapToInt

@MountPoint
public IntStream flatMapToInt(Function<? super T,? extends IntStream> mapper)

Specified by:

flatMapToInt in interface Stream<T>

flatMapToLong

@MountPoint
public LongStream flatMapToLong(Function<? super T,? extends LongStream> mapper)

Specified by:

flatMapToLong in interface Stream<T>

forEach

@MountPoint
public void forEach(Consumer<? super T> action)

Specified by:

forEach in interface Stream<T>

forEachOrdered

@MountPoint
public void forEachOrdered(Consumer<? super T> action)

Specified by:

forEachOrdered in interface Stream<T>

isParallel

@MountPoint
public boolean isParallel()

Specified by:

isParallel in interface BaseStream<T,Stream<T>>

iterator

@MountPoint
public Iterator<T> iterator()

Specified by:

iterator in interface BaseStream<T,Stream<T>>

limit

@MountPoint
public Stream<T> limit(long maxSize)

Specified by:

limit in interface Stream<T>

map

@MountPoint
public <R> Stream<R> map(Function<? super T,? extends R> mapper)

Specified by:

map in interface Stream<T>

mapToDouble

@MountPoint
public DoubleStream mapToDouble(ToDoubleFunction<? super T> mapper)

Specified by:

mapToDouble in interface Stream<T>

mapToInt

@MountPoint
public IntStream mapToInt(ToIntFunction<? super T> mapper)

Specified by:

mapToInt in interface Stream<T>

mapToLong

@MountPoint
public LongStream mapToLong(ToLongFunction<? super T> mapper)

Specified by:

mapToLong in interface Stream<T>

max

@MountPoint
public Optional<T> max(Comparator<? super T> comparator)

Specified by:

max in interface Stream<T>

min

@MountPoint
public Optional<T> min(Comparator<? super T> comparator)

Specified by:

min in interface Stream<T>

noneMatch

@MountPoint
public boolean noneMatch(Predicate<? super T> predicate)

Specified by:

noneMatch in interface Stream<T>

onClose

@MountPoint
public Stream<T> onClose(Runnable closeHandler)

Specified by:

onClose in interface BaseStream<T,Stream<T>>

parallel

@MountPoint
public Stream<T> parallel()

Specified by:

parallel in interface BaseStream<T,Stream<T>>

peek

@MountPoint
public Stream<T> peek(Consumer<? super T> action)

Specified by:

peek in interface Stream<T>

reduce

@MountPoint
public Optional<T> reduce(BinaryOperator<T> accumulator)

Specified by:

reduce in interface Stream<T>

reduce

@MountPoint
public T reduce(T identity,
 BinaryOperator<T> accumulator)

Specified by:

reduce in interface Stream<T>

reduce

@MountPoint
public <U> U reduce(U identity,
 BiFunction<U,? super T,U> accumulator,
 BinaryOperator<U> combiner)

Specified by:

reduce in interface Stream<T>

sequential

@MountPoint
public Stream<T> sequential()

Specified by:

sequential in interface BaseStream<T,Stream<T>>

skip

@MountPoint
public Stream<T> skip(long n)

Specified by:

skip in interface Stream<T>

sorted

@MountPoint
public Stream<T> sorted()

Specified by:

sorted in interface Stream<T>

sorted

@MountPoint
public Stream<T> sorted(Comparator<? super T> comparator)

Specified by:

sorted in interface Stream<T>

spliterator

@MountPoint
public Spliterator<T> spliterator()

Specified by:

spliterator in interface BaseStream<T,Stream<T>>

takeWhile

@MountPoint
public Stream<T> takeWhile(Predicate<? super T> predicate)

Specified by:

takeWhile in interface Stream<T>

toArray

@MountPoint
public Object[] toArray()

Specified by:

toArray in interface Stream<T>

toArray

@MountPoint
public <A> A[] toArray(IntFunction<A[]> generator)

Specified by:

toArray in interface Stream<T>

unordered

@MountPoint
public Stream<T> unordered()

Specified by:

unordered in interface BaseStream<T,Stream<T>>