Как реактивно генерировать события с динамической задержкой, используя Mutiny в Java?

Как я могу использовать Mutiny для периодического опроса новых событий из ресурса данных, в то же время задерживая выпуск каждого события на динамическое количество времени, чтобы свойство даты события было ровно одну секунду назад?

Каждый элемент в ресурсе данных содержит свойство даты, которое представляет время входа, и цель состоит в том, чтобы генерировать каждое событие через одну секунду после его времени входа. Я рассматриваю возможность использования Uni<List> (запросы к базе данных являются "однократными" операциями), но я бы предпочел, чтобы Multi объединял потоки в родительском классе.

private LocalDateTime timeOfLastQuery;

public Multi<Event> getNewEvents() {
        final var eventStream = Multi.createFrom().iterable(getNewEvents(timeOfLastQuery))
                //todo delay item by millisToOneSecondOld
                .onItem().transform(mapper::toEvent);

        timeOfLastQuery = LocalDateTime.now();

        return eventStream;
    }

    private Long millisToOneSecondOld(LocalDateTime timeOfEntry) {
        final var aSecondAgo = LocalDateTime.now().minusSeconds(1);
        final var duration = Duration.between(aSecondAgo, timeOfEntry);
        return coerceAtLeast(duration.toMillis(),0);
    }

    public static long coerceAtLeast(long x, long minimum) {
        return Math.max(x, minimum);
    }