Uses of Interface
io.axoniq.axonserver.connector.event.transformation.event.TransformableEventStream

Packages that use TransformableEventStream

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

Uses of TransformableEventStream in io.axoniq.axonserver.connector.event.transformation.event

Methods in io.axoniq.axonserver.connector.event.transformation.event that return TransformableEventStream

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

Uses of TransformableEventStream in io.axoniq.axonserver.connector.event.transformation.event.impl

Classes in io.axoniq.axonserver.connector.event.transformation.event.impl that implement TransformableEventStream

Modifier and Type	Class	Description
class	TransformableEventIterable	TransformableEventStream implementation that is based on an Iterable.

Methods in io.axoniq.axonserver.connector.event.transformation.event.impl that return TransformableEventStream

Modifier and Type	Method	Description
TransformableEventStream	TransformableEventIterable.filter(Predicate<EventWithToken> predicate)