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 ffc1f5cce2..bb6abdb4db 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
@@ -120,12 +120,12 @@ public class ReactiveStreamsTests {
 								.map(Message::getPayload)
 								.take(7)
 								.collectList()
-								.block(Duration.ofSeconds(5)));
+								.block(Duration.ofSeconds(10)));
 
 		this.inputChannel.send(new GenericMessage<>("6,7,8,9,10"));
 
 		assertTrue(latch.await(10, TimeUnit.SECONDS));
-		List<Integer> integers = future.get(10, TimeUnit.SECONDS);
+		List<Integer> integers = future.get(20, TimeUnit.SECONDS);
 		assertNotNull(integers);
 		assertEquals(7, integers.size());
 	}