Class AggregateEventStream<T>

java.lang.Object
io.fluxcapacitor.javaclient.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(java.lang.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).