Class TokenRangeEvents
- java.lang.Object
-
- io.axoniq.axonserver.connector.event.transformation.event.stream.TokenRangeEvents
-
- All Implemented Interfaces:
Iterable<EventWithToken>
public class TokenRangeEvents extends Object implements Iterable<EventWithToken>
EventWithTokens'Iterablethat start from a given initial token and completes at the last token.- Since:
- 2023.0.0
- Author:
- Sara Pellegrini
-
-
Constructor Summary
Constructors Constructor Description TokenRangeEvents(Supplier<EventChannel> eventChannel, long firstToken, long lastToken)Constructs an instance based on the specified parameters.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Iterator<EventWithToken>iterator()-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface java.lang.Iterable
forEach, spliterator
-
-
-
-
Constructor Detail
-
TokenRangeEvents
public TokenRangeEvents(Supplier<EventChannel> eventChannel, long firstToken, long lastToken)
Constructs an instance based on the specified parameters.- Parameters:
eventChannel- the channel used to open a stream to Axon Server for reading eventsfirstToken- the first token to includelastToken- the last token to include
-
-
Method Detail
-
iterator
public Iterator<EventWithToken> iterator()
- Specified by:
iteratorin interfaceIterable<EventWithToken>
-
-