Uses of Class
io.fluxcapacitor.javaclient.persisting.eventsourcing.AggregateEventStream

Packages that use AggregateEventStream

Package	Description
io.fluxcapacitor.javaclient.persisting.eventsourcing
io.fluxcapacitor.javaclient.persisting.eventsourcing.client

Uses of AggregateEventStream in io.fluxcapacitor.javaclient.persisting.eventsourcing

Methods in io.fluxcapacitor.javaclient.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.fluxcapacitor.javaclient.persisting.eventsourcing.client

Methods in io.fluxcapacitor.javaclient.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.