Uses of Interface
org.axonframework.eventsourcing.eventstore.DomainEventStream

Packages that use DomainEventStream

Package	Description
org.axonframework.axonserver.connector.event.axon
org.axonframework.eventsourcing	Classes related to event sourcing.
org.axonframework.eventsourcing.eventstore	Definitions and implementations of the Event store, the mechanism that can load event streams and append events to them.
org.axonframework.eventsourcing.eventstore.inmemory

Uses of DomainEventStream in org.axonframework.axonserver.connector.event.axon

Methods in org.axonframework.axonserver.connector.event.axon that return DomainEventStream

Modifier and Type	Method and Description
DomainEventStream	AxonServerEventStore.readEvents(String aggregateIdentifier)

Uses of DomainEventStream in org.axonframework.eventsourcing

Methods in org.axonframework.eventsourcing that return DomainEventStream

Modifier and Type	Method and Description
DomainEventStream	FilteringEventStorageEngine.readEvents(String aggregateIdentifier)
protected DomainEventStream	EventSourcingRepository.readEvents(String aggregateIdentifier) Reads the events for the given aggregateIdentifier from the eventStore.
DomainEventStream	FilteringEventStorageEngine.readEvents(String aggregateIdentifier, long firstSequenceNumber)
static DomainEventStream	EventStreamUtils.upcastAndDeserializeDomainEvents(Stream<? extends DomainEventData<?>> eventEntryStream, Serializer serializer, EventUpcaster upcasterChain) Upcasts and deserializes the given eventEntryStream using the given serializer and upcasterChain.

Methods in org.axonframework.eventsourcing with parameters of type DomainEventStream

Modifier and Type	Method and Description
static Stream<? extends DomainEventMessage<?>>	EventStreamUtils.asStream(DomainEventStream domainEventStream) Convert the given domainEventStream to a regular java Stream of domain event messages.
protected DomainEventMessage	AggregateSnapshotter.createSnapshot(Class<?> aggregateType, String aggregateIdentifier, DomainEventStream eventStream)
protected abstract DomainEventMessage	AbstractSnapshotter.createSnapshot(Class<?> aggregateType, String aggregateIdentifier, DomainEventStream eventStream) Creates a snapshot event for an aggregate of which passed events are available in the given eventStream.
void	EventSourcedAggregate.initializeState(DomainEventStream eventStream) Initialize the state of this Event Sourced Aggregate with the events from the given eventStream.

Uses of DomainEventStream in org.axonframework.eventsourcing.eventstore

Classes in org.axonframework.eventsourcing.eventstore that implement DomainEventStream

Modifier and Type	Class and Description
class	ConcatenatingDomainEventStream DomainEventStream implementation that concatenates multiple streams, taking into account that some sequence numbers may appear in more than one stream.
class	FilteringDomainEventStream DomainEventStream implementation that filters a stream.
class	IteratorBackedDomainEventStream DomainEventStream implementation that gets its messages from an Iterator.

Methods in org.axonframework.eventsourcing.eventstore that return DomainEventStream

Modifier and Type	Method and Description
static DomainEventStream	DomainEventStream.concat(DomainEventStream a, DomainEventStream b) Concatenate two DomainEventStreams.
static DomainEventStream	DomainEventStream.empty() Create an empty DomainEventStream.
default DomainEventStream	DomainEventStream.filter(Predicate<? super DomainEventMessage<?>> filter) Returns a stream that provides the items of this stream that match the given filter.
static DomainEventStream	DomainEventStream.of(DomainEventMessage<?>... events) Create a new DomainEventStream from the given events.
static DomainEventStream	DomainEventStream.of(DomainEventMessage<?> event) Create a new DomainEventStream containing only the given event.
static DomainEventStream	DomainEventStream.of(List<? extends DomainEventMessage<?>> list) Create a new DomainEventStream with events obtained from the given list.
static DomainEventStream	DomainEventStream.of(Stream<? extends DomainEventMessage<?>> stream) Create a new DomainEventStream with events obtained from the given stream.
static DomainEventStream	DomainEventStream.of(Stream<? extends DomainEventMessage<?>> stream, Supplier<Long> sequenceNumberSupplier) Create a new DomainEventStream with events obtained from the given stream.
DomainEventStream	EventStore.readEvents(String aggregateIdentifier) Open an event stream containing all domain events belonging to the given aggregateIdentifier.
default DomainEventStream	EventStorageEngine.readEvents(String aggregateIdentifier) Get a DomainEventStream containing all events published by the aggregate with given aggregateIdentifier.
DomainEventStream	AbstractEventStore.readEvents(String aggregateIdentifier) Open an event stream containing all domain events belonging to the given aggregateIdentifier.
DomainEventStream	SequenceEventStorageEngine.readEvents(String aggregateIdentifier, long firstSequenceNumber)
default DomainEventStream	EventStore.readEvents(String aggregateIdentifier, long firstSequenceNumber) Open an event stream containing all domain events belonging to the given aggregateIdentifier.
DomainEventStream	EventStorageEngine.readEvents(String aggregateIdentifier, long firstSequenceNumber) Get a DomainEventStream containing all events published by the aggregate with given aggregateIdentifier starting with the first event having a sequence number that is equal or larger than the given firstSequenceNumber.
DomainEventStream	AbstractEventStore.readEvents(String aggregateIdentifier, long firstSequenceNumber)
DomainEventStream	AbstractEventStorageEngine.readEvents(String aggregateIdentifier, long firstSequenceNumber)

Methods in org.axonframework.eventsourcing.eventstore with parameters of type DomainEventStream

Modifier and Type	Method and Description
static DomainEventStream	DomainEventStream.concat(DomainEventStream a, DomainEventStream b) Concatenate two DomainEventStreams.

Constructors in org.axonframework.eventsourcing.eventstore with parameters of type DomainEventStream

Constructor and Description
ConcatenatingDomainEventStream(DomainEventStream... streams) Initialize the stream, concatenating the given streams.
FilteringDomainEventStream(DomainEventStream delegate, Predicate<? super DomainEventMessage<?>> filter) Initialize the stream, filter the given stream with the given filter.

Constructor parameters in org.axonframework.eventsourcing.eventstore with type arguments of type DomainEventStream

Constructor and Description
ConcatenatingDomainEventStream(Collection<DomainEventStream> streams) Initialize the stream, concatenating the given streams.

Uses of DomainEventStream in org.axonframework.eventsourcing.eventstore.inmemory

Methods in org.axonframework.eventsourcing.eventstore.inmemory that return DomainEventStream

Modifier and Type	Method and Description
DomainEventStream	InMemoryEventStorageEngine.readEvents(String aggregateIdentifier, long firstSequenceNumber)