Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.connector.event.transformation.event

Interface EventSources

public interface EventSources

Provides various ways to get TransformableEventStream.

Since:

2023.1.0

Author:

Sara Pellegrini

Method Summary

Static Methods

Modifier and Type	Method	Description
static TransformableEventStream	fromIterable(Iterable<EventWithToken> events)	Creates a TransformableEventStream based on the Iterable of events.
static TransformableEventStream	range(Supplier<EventChannel> eventChannelSupplier, long first, long last)	Creates a TransformableEventStream based on the eventChannelSupplier and first and last event tokens.

Method Detail

fromIterable

static TransformableEventStream fromIterable(Iterable<EventWithToken> events)

Creates a TransformableEventStream based on the Iterable of events.

Parameters:

events - Iterable of events

Returns:

TransformableEventStream

range

static TransformableEventStream range(Supplier<EventChannel> eventChannelSupplier,
                                      long first,
                                      long last)

Creates a TransformableEventStream based on the eventChannelSupplier and first and last event tokens.

Parameters:

eventChannelSupplier - supplies the EventChannel

first - the first token to be included in the stream, should be -1 to start from the beginning

last - the last token to be included in the stream

Returns:

TransformableEventStream