Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Increase timeout in the ReactiveStreamsTests

Browse Source
This commit is contained in:
Artem Bilan
2016-11-16 10:33:43 -05:00
parent ba576bbc0d
commit d42357ba02
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-integration-core/src/test/java/org/springframework/integration/dsl/reactivestreams/ReactiveStreamsTests.java
View File

@@ -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());
}