org.axonframework.eventsourcing.eventstore

Class FilteringDomainEventStream

java.lang.Object

org.axonframework.eventsourcing.eventstore.FilteringDomainEventStream

All Implemented Interfaces:

Iterator<DomainEventMessage<?>>, DomainEventStream

public class FilteringDomainEventStream
extends Object
implements DomainEventStream

DomainEventStream implementation that filters a stream.

Since:

3.3

Author:

André Bierwolf

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
Long	getLastSequenceNumber() Get the highest known sequence number in the upstream event entry stream.
boolean	hasNext() Returns true if the stream has more events, meaning that a call to next() will not result in an exception.
DomainEventMessage<?>	next() Returns the next events in the stream, if available.
DomainEventMessage<?>	peek() Returns the next events in the stream, if available, without moving the pointer forward.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.axonframework.eventsourcing.eventstore.DomainEventStream

asStream, concat, empty, filter, of, of, of, of, of, remove

Methods inherited from interface java.util.Iterator

forEachRemaining

Constructor Detail

FilteringDomainEventStream

public FilteringDomainEventStream(DomainEventStream delegate,
                                  Predicate<? super DomainEventMessage<?>> filter)

Initialize the stream, filter the given stream with the given filter.

Parameters:

delegate - The stream providing the elements

filter - The filter to apply to the delegate stream

Method Detail

peek

public DomainEventMessage<?> peek()

Description copied from interface: DomainEventStream

Returns the next events in the stream, if available, without moving the pointer forward. Hence, a call to DomainEventStream.next() will return the same event as a call to peek(). Use hasNext() to obtain a guarantee about the availability of any next event.

If the pointer has reached the end of the stream, the behavior of this method is undefined. It could either return null, or throw an exception, depending on the actual implementation. Use DomainEventStream.hasNext() to confirm the existence of elements after the current pointer.

Specified by:

peek in interface DomainEventStream

Returns:

the next event in the stream.

hasNext

public boolean hasNext()

Description copied from interface: DomainEventStream

Returns true if the stream has more events, meaning that a call to next() will not result in an exception. If a call to this method returns false, there is no guarantee about the result of a consecutive call to next()

Specified by:

hasNext in interface Iterator<DomainEventMessage<?>>

Specified by:

hasNext in interface DomainEventStream

Returns:

true if the stream contains more events.

next

public DomainEventMessage<?> next()

Description copied from interface: DomainEventStream

Returns the next events in the stream, if available. Use hasNext() to obtain a guarantee about the availability of any next event. Each call to next() will forward the pointer to the next event in the stream.

If the pointer has reached the end of the stream, the behavior of this method is undefined. It could either return null, or throw an exception, depending on the actual implementation. Use DomainEventStream.hasNext() to confirm the existence of elements after the current pointer.

Specified by:

next in interface Iterator<DomainEventMessage<?>>

Specified by:

next in interface DomainEventStream

Returns:

the next event in the stream.

getLastSequenceNumber

public Long getLastSequenceNumber()

Description copied from interface: DomainEventStream

Get the highest known sequence number in the upstream event entry stream. Note that, as result of upcasting it is possible that the last event in this stream has a lower sequence number than that returned by this method.

To get the highest absolute sequence number of the underlying event entry stream make sure to iterate over all elements in the stream before calling this method.

If the stream is empty this method returns null.

Specified by:

getLastSequenceNumber in interface DomainEventStream

Returns:

the sequence number of the last known upstream event entry