huahaofeng
/
aspnetcore
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Increase more SignalR Java client test timeouts (#26036) 

Co-authored-by: Stephen Halter <halter73@gmail.com>
This commit is contained in:
Pranav K 2020-09-18 17:00:43 -07:00 committed by GitHub
parent 140f177d9e
commit bf91253cd3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/SignalR/clients/java/signalr/test/src/main/java/com/microsoft/signalr/HubConnectionTest.java
View File

@ -2515,14 +2515,14 @@ class HubConnectionTest {
value2.set(param1); value2.set(param1);
}, String.class); }, String.class);
hubConnection.start().timeout(1, TimeUnit.SECONDS).blockingAwait(); hubConnection.start().timeout(30, TimeUnit.SECONDS).blockingAwait();
mockTransport.receiveMessage("{\"type\":1,\"target\":\"inc\",\"arguments\":[\"Hello World\"]}" + RECORD_SEPARATOR); mockTransport.receiveMessage("{\"type\":1,\"target\":\"inc\",\"arguments\":[\"Hello World\"]}" + RECORD_SEPARATOR);
// Confirming that our handler was called and the correct message was passed in. // Confirming that our handler was called and the correct message was passed in.
assertEquals("Hello World", value1.get()); assertEquals("Hello World", value1.get());
assertEquals("Hello World", value2.get()); assertEquals("Hello World", value2.get());
hubConnection.stop().timeout(1, TimeUnit.SECONDS).blockingAwait(); hubConnection.stop().timeout(30, TimeUnit.SECONDS).blockingAwait();
ILoggingEvent log = logger.assertLog("Invoking client side method 'inc' failed:"); ILoggingEvent log = logger.assertLog("Invoking client side method 'inc' failed:");
assertEquals("throw from on handler", log.getThrowableProxy().getMessage()); assertEquals("throw from on handler", log.getThrowableProxy().getMessage());

2
src/SignalR/clients/java/signalr/test/src/main/java/com/microsoft/signalr/LongPollingTransportTest.java
View File

@ -392,7 +392,7 @@ public class LongPollingTransportTest {
Map<String, String> headers = new HashMap<>(); Map<String, String> headers = new HashMap<>();
LongPollingTransport transport = new LongPollingTransport(headers, client, Single.just("")); LongPollingTransport transport = new LongPollingTransport(headers, client, Single.just(""));
transport.start("http://example.com").timeout(100, TimeUnit.SECONDS).blockingAwait(); transport.start("http://example.com").timeout(30, TimeUnit.SECONDS).blockingAwait();
RuntimeException exception = assertThrows(RuntimeException.class, () -> transport.stop().blockingAwait(100, TimeUnit.SECONDS)); RuntimeException exception = assertThrows(RuntimeException.class, () -> transport.stop().blockingAwait(100, TimeUnit.SECONDS));
assertEquals("Request has no handler: DELETE http://example.com", exception.getMessage()); assertEquals("Request has no handler: DELETE http://example.com", exception.getMessage());