Publishing hang

MAIF · Dec 8, 2023 · f6083a9 · f6083a9
1 parent 96ae107
commit f6083a9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/thoth-jooq-reactor/src/test/java/fr/maif/eventsourcing/AbstractPostgresEventStoreTest.java b/thoth-jooq-reactor/src/test/java/fr/maif/eventsourcing/AbstractPostgresEventStoreTest.java
@@ -234,7 +234,7 @@ public void loadEventsUnpublishedWait() throws InterruptedException {
         initDatas();
         CompletionStage<java.util.List<EventEnvelope<VikingEvent, Void, Void>>> first = transactionSource().flatMapMany(t ->
                 Flux.from(postgresEventStore.loadEventsUnpublished(t, WAIT))
-                        .concatMap(elt -> Flux.interval(Duration.ofMillis(100), Duration.ofMillis(100)).map(__ -> elt).take(1))
+                        .concatMap(elt -> Mono.delay(Duration.ofMillis(120)).map(__ -> elt))
                         .concatMap(e -> Mono.fromCompletionStage(() -> postgresEventStore.markAsPublished(t, e).toCompletableFuture()).map(__ -> e))
                         .doFinally(it -> t.commit())
         ).collectList().toFuture();