Uses of Class
io.fluxzero.sdk.persisting.eventsourcing.AggregateEventStream

Packages that use AggregateEventStream

Package	Description
io.fluxzero.sdk.persisting.eventsourcing
io.fluxzero.sdk.persisting.eventsourcing.client

Uses of AggregateEventStream in io.fluxzero.sdk.persisting.eventsourcing

Methods in io.fluxzero.sdk.persisting.eventsourcing that return AggregateEventStream

Modifier and Type	Method	Description
<O> AggregateEventStream<O>	AggregateEventStream.convert(Function<Stream<T>, Stream<O>> streamConverter)	Transforms the underlying stream of events using a given stream converter function.
AggregateEventStream<DeserializingMessage>	DefaultEventStore.getEvents(Object aggregateId, long lastSequenceNumber, int maxSize, boolean ignoreUnknownType)
default AggregateEventStream<DeserializingMessage>	EventStore.getEvents(Object aggregateId)	Retrieves the full event stream for an aggregate starting from the beginning.
default AggregateEventStream<DeserializingMessage>	EventStore.getEvents(Object aggregateId, long lastSequenceNumber)	Retrieves the event stream for an aggregate starting after the specified sequence number.
default AggregateEventStream<DeserializingMessage>	EventStore.getEvents(Object aggregateId, long lastSequenceNumber, int maxSize)	Retrieves the event stream for an aggregate starting after a given sequence number, with a maximum limit.
AggregateEventStream<DeserializingMessage>	EventStore.getEvents(Object aggregateId, long lastSequenceNumber, int maxSize, boolean ignoreUnknownType)	Retrieves the event stream for an aggregate with full control over behavior.

Uses of AggregateEventStream in io.fluxzero.sdk.persisting.eventsourcing.client

Methods in io.fluxzero.sdk.persisting.eventsourcing.client that return AggregateEventStream

Modifier and Type	Method	Description
default AggregateEventStream<SerializedMessage>	EventStoreClient.getEvents(String aggregateId)	Retrieves the full event stream for a given aggregate.
default AggregateEventStream<SerializedMessage>	EventStoreClient.getEvents(String aggregateId, long lastSequenceNumber)	Retrieves the event stream for an aggregate starting after the given sequence number.
AggregateEventStream<SerializedMessage>	EventStoreClient.getEvents(String aggregateId, long lastSequenceNumber, int maxSize)	Retrieves the event stream for an aggregate with control over size and offset.
AggregateEventStream<SerializedMessage>	InMemoryEventStore.getEvents(String aggregateId, long lastSequenceNumber, int maxSize)
AggregateEventStream<SerializedMessage>	WebSocketEventStoreClient.getEvents(String aggregateId, long lastSequenceNumber, int maxSize)	Retrieves events for a specific aggregate starting after a given sequence number, optionally limiting the result size.