diff --git a/spring-integration-core/src/test/java/org/springframework/integration/dsl/reactivestreams/ReactiveStreamsTests.java b/spring-integration-core/src/test/java/org/springframework/integration/dsl/reactivestreams/ReactiveStreamsTests.java
index b1a4094b6f..64dbf1b1d1 100644
--- a/spring-integration-core/src/test/java/org/springframework/integration/dsl/reactivestreams/ReactiveStreamsTests.java
+++ b/spring-integration-core/src/test/java/org/springframework/integration/dsl/reactivestreams/ReactiveStreamsTests.java
@@ -306,7 +306,9 @@ public class ReactiveStreamsTests {
 		public Publisher<Message<String>> reactiveFlow() {
 			return IntegrationFlow
 					.from(() -> new GenericMessage<>("a,b,c,d,e,f"),
-							e -> e.poller(p -> p.trigger(ctx -> this.invoked.getAndSet(true) ? null : Instant.now()))
+							e -> e.poller(p ->
+											p.trigger(ctx ->
+													this.invoked.getAndSet(true) ? null : Instant.now().plusMillis(1000)))
 									.sendTimeout(256)
 									.id("reactiveStreamsMessageSource"))
 					.split(String.class, p -> p.split(","))