Module io.axoniq.connector.axonserver

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

Class IterableEventTransformationExecutor

java.lang.Object

io.axoniq.axonserver.connector.event.transformation.event.impl.IterableEventTransformationExecutor

All Implemented Interfaces:

EventTransformationExecutor

public class IterableEventTransformationExecutor
extends Object
implements EventTransformationExecutor

EventTransformationExecutor implementation based on an Iterable of EventWithToken.

Since:

2023.1.0

Author:

Sara Pellegrini

Method Summary

Modifier and Type	Method	Description
CompletableFuture<EventTransformation>	execute(Supplier<EventTransformationChannel> channelSupplier)	Executes the Transformation by invoking APPLY operation.

Methods inherited from class java.lang.Object

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

Method Detail

execute

public CompletableFuture<EventTransformation> execute(Supplier<EventTransformationChannel> channelSupplier)

Description copied from interface: EventTransformationExecutor

Executes the Transformation by invoking APPLY operation.

Specified by:

execute in interface EventTransformationExecutor

Parameters:

channelSupplier - supplies the EventTransformationChannel

Returns:

a CompletableFuture to indicate when the APPLY process has been accepted