From d42357ba0214f522e063de3aacb251a241d54345 Mon Sep 17 00:00:00 2001
From: Artem Bilan <abilan@pivotal.io>
Date: Wed, 16 Nov 2016 10:33:43 -0500
Subject: [PATCH] Increase timeout 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 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());
 	}