Package io.axoniq.framework.workflow.runtime.test.utils

Class DelayedPublisher

java.lang.Object

io.axoniq.framework.workflow.runtime.test.utils.DelayedPublisher

public class DelayedPublisher
extends Object

Publisher that delays the publication of events.

Since:

5.4.0

Author:

Simon Zambrovski

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	DelayedPublisher.Schedule

Constructor Summary

Constructors

Constructor	Description
DelayedPublisher(TestEventPublisher eventPublisher, Executor executor)

Method Summary

Modifier and Type	Method	Description
void	addSchedules(List<DelayedPublisher.Schedule> schedules)
CompletableFuture<Void>	start()

Methods inherited from class java.lang.Object

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

Constructor Details

DelayedPublisher

public DelayedPublisher(TestEventPublisher eventPublisher,
 Executor executor)

Method Details

addSchedules

public void addSchedules(List<DelayedPublisher.Schedule> schedules)

start

public CompletableFuture<Void> start()