fixes test timeout

OlegDokuka · OlegDokuka · commit c78bab2d768b · 2019-03-28T23:04:34.000+01:00
Signed-off-by: Robert Roeser &lt;rroeserr@gmail.com&gt;
Signed-off-by: Oleh Dokuka &lt;shadowgun@i.ua&gt;
diff --git a/rsocket-examples/src/test/java/io/rsocket/integration/TcpIntegrationTest.java b/rsocket-examples/src/test/java/io/rsocket/integration/TcpIntegrationTest.java
@@ -151,7 +151,7 @@ public Mono<Payload> requestResponse(Payload payload) {
     assertEquals("SUCCESS", response2.getDataUtf8());
   }
 
-  @Test(timeout = 15_000L)
+  @Test(timeout = 35_000L)
   public void testTwoConcurrentStreams() throws InterruptedException {
     ConcurrentHashMap<String, UnicastProcessor<Payload>> map = new ConcurrentHashMap<>();
     UnicastProcessor<Payload> processor1 = UnicastProcessor.create();

Original file line number	Diff line number	Diff line change
`@@ -151,7 +151,7 @@ public Mono<Payload> requestResponse(Payload payload) {`
`151`	`151`	`assertEquals("SUCCESS", response2.getDataUtf8());`
`152`	`152`	`}`
`153`	`153`
`154`		`- @Test(timeout = 15_000L)`
	`154`	`+ @Test(timeout = 35_000L)`
`155`	`155`	`public void testTwoConcurrentStreams() throws InterruptedException {`
`156`	`156`	`ConcurrentHashMap<String, UnicastProcessor<Payload>> map = new ConcurrentHashMap<>();`
`157`	`157`	`UnicastProcessor<Payload> processor1 = UnicastProcessor.create();`