Class AggregateEventStream<T>

java.lang.Object

io.fluxzero.sdk.persisting.eventsourcing.AggregateEventStream<T>

Type Parameters:

T - The type of event elements in the stream.

All Implemented Interfaces:

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

public class AggregateEventStream<T>
extends Object
implements Stream<T>

A wrapper around a stream of aggregate events, enriched with metadata such as the aggregate ID and the last known sequence number.

This type is returned by EventStore.getEvents(Object) and provides access to the raw or deserialized event stream, along with information necessary for event-sourced state reconstruction (like the latest known sequence number).

Nested Class Summary

Nested classes/interfaces inherited from interface Stream

Stream.Builder<T>

Constructor Summary

Constructors

Constructor	Description
AggregateEventStream()

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)
<O> AggregateEventStream<O>	convert(Function<Stream<T>, Stream<O>> streamConverter)	Transforms the underlying stream of events using a given stream converter function.
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)
Optional<Long>	getLastSequenceNumber()	Returns the last known sequence number from the event stream, if available.
boolean	isParallel()
@NonNull Iterator<T>	iterator()
Stream<T>	limit(long maxSize)
<R> Stream<R>	map(Function<? super T, ? extends R> mapper)
<R> Stream<R>	mapMulti(BiConsumer<? super T, ? super Consumer<R>> mapper)
DoubleStream	mapMultiToDouble(BiConsumer<? super T, ? super DoubleConsumer> mapper)
IntStream	mapMultiToInt(BiConsumer<? super T, ? super IntConsumer> mapper)
LongStream	mapMultiToLong(BiConsumer<? super T, ? super LongConsumer> 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)
List<T>	toList()
Stream<T>	unordered()

Methods inherited from class Object

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

Constructor Details

AggregateEventStream

public AggregateEventStream()

Method Details

convert

public <O> AggregateEventStream<O> convert(Function<Stream<T>, Stream<O>> streamConverter)

Transforms the underlying stream of events using a given stream converter function. The returned instance retains the same aggregate ID and sequence number metadata.

Type Parameters:

O - The output type of the converted stream.

Parameters:

streamConverter - A function that converts the original stream to another stream type.

Returns:

A new AggregateEventStream wrapping the converted stream.

getLastSequenceNumber

public Optional<Long> getLastSequenceNumber()

Returns the last known sequence number from the event stream, if available.

Returns:

An Optional containing the sequence number, or empty if not set.

iterator

@NonNull
public @NonNull Iterator<T> iterator()

Specified by:

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

filter

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

Specified by:

filter in interface Stream<T>

map

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

Specified by:

map in interface Stream<T>

mapToInt

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

Specified by:

mapToInt in interface Stream<T>

mapToLong

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

Specified by:

mapToLong in interface Stream<T>

mapToDouble

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

Specified by:

mapToDouble in interface Stream<T>

flatMap

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

Specified by:

flatMap in interface Stream<T>

flatMapToInt

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

Specified by:

flatMapToInt in interface Stream<T>

flatMapToLong

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

Specified by:

flatMapToLong in interface Stream<T>

flatMapToDouble

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

Specified by:

flatMapToDouble in interface Stream<T>

mapMulti

public <R> Stream<R> mapMulti(BiConsumer<? super T, ? super Consumer<R>> mapper)

Specified by:

mapMulti in interface Stream<T>

mapMultiToInt

public IntStream mapMultiToInt(BiConsumer<? super T, ? super IntConsumer> mapper)

Specified by:

mapMultiToInt in interface Stream<T>

mapMultiToLong

public LongStream mapMultiToLong(BiConsumer<? super T, ? super LongConsumer> mapper)

Specified by:

mapMultiToLong in interface Stream<T>

mapMultiToDouble

public DoubleStream mapMultiToDouble(BiConsumer<? super T, ? super DoubleConsumer> mapper)

Specified by:

mapMultiToDouble in interface Stream<T>

distinct

public Stream<T> distinct()

Specified by:

distinct in interface Stream<T>

sorted

public Stream<T> sorted()

Specified by:

sorted in interface Stream<T>

sorted

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

Specified by:

sorted in interface Stream<T>

peek

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

Specified by:

peek in interface Stream<T>

limit

public Stream<T> limit(long maxSize)

Specified by:

limit in interface Stream<T>

skip

public Stream<T> skip(long n)

Specified by:

skip in interface Stream<T>

takeWhile

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

Specified by:

takeWhile in interface Stream<T>

dropWhile

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

Specified by:

dropWhile in interface Stream<T>

forEach

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

Specified by:

forEach in interface Stream<T>

forEachOrdered

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

Specified by:

forEachOrdered in interface Stream<T>

toArray

@NotNull
public Object[] toArray()

Specified by:

toArray in interface Stream<T>

toArray

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

Specified by:

toArray in interface Stream<T>

reduce

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

Specified by:

reduce in interface Stream<T>

reduce

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

Specified by:

reduce in interface Stream<T>

reduce

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

Specified by:

reduce in interface Stream<T>

collect

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

Specified by:

collect in interface Stream<T>

collect

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

Specified by:

collect in interface Stream<T>

toList

public List<T> toList()

Specified by:

toList in interface Stream<T>

min

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

Specified by:

min in interface Stream<T>

max

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

Specified by:

max in interface Stream<T>

count

public long count()

Specified by:

count in interface Stream<T>

anyMatch

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

Specified by:

anyMatch in interface Stream<T>

allMatch

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

Specified by:

allMatch in interface Stream<T>

noneMatch

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

Specified by:

noneMatch in interface Stream<T>

findFirst

@NotNull
public Optional<T> findFirst()

Specified by:

findFirst in interface Stream<T>

findAny

@NotNull
public Optional<T> findAny()

Specified by:

findAny in interface Stream<T>

spliterator

@NotNull
public Spliterator<T> spliterator()

Specified by:

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

isParallel

public boolean isParallel()

Specified by:

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

sequential

@NotNull
public Stream<T> sequential()

Specified by:

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

parallel

@NotNull
public Stream<T> parallel()

Specified by:

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

unordered

@NotNull
public Stream<T> unordered()

Specified by:

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

onClose

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

Specified by:

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

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

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