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	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	Description
protected DomainEventStream	EventSourcingRepository.readEvents(String aggregateIdentifier)	Reads the events for the given aggregateIdentifier from the eventStore. this method may be overridden to add pre or postprocessing to the loading of an event stream
DomainEventStream	FilteringEventStorageEngine.readEvents(String aggregateIdentifier)
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	Description
static Stream<? extends DomainEventMessage<?>>	EventStreamUtils.asStream(DomainEventStream domainEventStream)	Convert the given domainEventStream to a regular java Stream of domain event messages.
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.
protected DomainEventMessage	AggregateSnapshotter.createSnapshot(Class<?> aggregateType, String aggregateIdentifier, DomainEventStream 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	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	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(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.
static DomainEventStream	DomainEventStream.of(DomainEventMessage<?> event)	Create a new DomainEventStream containing only the given event.
static DomainEventStream	DomainEventStream.of(DomainEventMessage<?>... events)	Create a new DomainEventStream from the given events.
DomainEventStream	AbstractEventStorageEngine.readEvents(String aggregateIdentifier, long firstSequenceNumber)
DomainEventStream	AbstractEventStore.readEvents(String aggregateIdentifier)	Open an event stream containing all domain events belonging to the given aggregateIdentifier.
DomainEventStream	AbstractEventStore.readEvents(String aggregateIdentifier, long firstSequenceNumber)
default DomainEventStream	EventStorageEngine.readEvents(String aggregateIdentifier)	Get a DomainEventStream containing all events published by the aggregate with 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	EventStore.readEvents(String aggregateIdentifier)	Open an event stream containing all domain events belonging to the given aggregateIdentifier.
default DomainEventStream	EventStore.readEvents(String aggregateIdentifier, long firstSequenceNumber)	Open an event stream containing all domain events belonging to the given aggregateIdentifier.
DomainEventStream	SequenceEventStorageEngine.readEvents(String aggregateIdentifier, long firstSequenceNumber)

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

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

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

Modifier	Constructor	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

Modifier	Constructor	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	Description
DomainEventStream	InMemoryEventStorageEngine.readEvents(String aggregateIdentifier, long firstSequenceNumber)