From 8d7b5f636e1cecd74f9e645156169e804e693453 Mon Sep 17 00:00:00 2001
From: Artem Bilan <artem.bilan@broadcom.com>
Date: Tue, 3 Jun 2025 13:10:33 -0400
Subject: [PATCH] Increase some timeouts in the `ReactiveStreamsTests`

---
 .../integration/dsl/reactivestreams/ReactiveStreamsTests.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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 64dbf1b1d1..54a2cdf947 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
@@ -152,13 +152,13 @@ public class ReactiveStreamsTests {
 								.take(7)
 								.map(Message::getPayload)
 								.collectList()
-								.block(Duration.ofSeconds(10))
+								.block(Duration.ofSeconds(20))
 				);
 
 		this.inputChannel.send(new GenericMessage<>("6,7,8,9,10"));
 
 		assertThat(latch.await(20, TimeUnit.SECONDS)).isTrue();
-		List<Integer> integers = future.get(20, TimeUnit.SECONDS);
+		List<Integer> integers = future.get(30, TimeUnit.SECONDS);
 
 		assertThat(integers).isNotNull();
 		assertThat(integers.size()).isEqualTo(7);