Skip to content

Commit bf91253

Browse files
pranavkmhalter73
andauthored
Increase more SignalR Java client test timeouts (#26036)
Co-authored-by: Stephen Halter <[email protected]>
1 parent 140f177 commit bf91253

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2515,14 +2515,14 @@ public void throwFromOnHandlerRunsAllHandlers() {
25152515
value2.set(param1);
25162516
}, String.class);
25172517

2518-
hubConnection.start().timeout(1, TimeUnit.SECONDS).blockingAwait();
2518+
hubConnection.start().timeout(30, TimeUnit.SECONDS).blockingAwait();
25192519
mockTransport.receiveMessage("{\"type\":1,\"target\":\"inc\",\"arguments\":[\"Hello World\"]}" + RECORD_SEPARATOR);
25202520

25212521
// Confirming that our handler was called and the correct message was passed in.
25222522
assertEquals("Hello World", value1.get());
25232523
assertEquals("Hello World", value2.get());
25242524

2525-
hubConnection.stop().timeout(1, TimeUnit.SECONDS).blockingAwait();
2525+
hubConnection.stop().timeout(30, TimeUnit.SECONDS).blockingAwait();
25262526

25272527
ILoggingEvent log = logger.assertLog("Invoking client side method 'inc' failed:");
25282528
assertEquals("throw from on handler", log.getThrowableProxy().getMessage());

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -392,7 +392,7 @@ public void ErrorFromClosePropagatesOnSecondStopCall() {
392392
Map<String, String> headers = new HashMap<>();
393393
LongPollingTransport transport = new LongPollingTransport(headers, client, Single.just(""));
394394

395-
transport.start("http://example.com").timeout(100, TimeUnit.SECONDS).blockingAwait();
395+
transport.start("http://example.com").timeout(30, TimeUnit.SECONDS).blockingAwait();
396396

397397
RuntimeException exception = assertThrows(RuntimeException.class, () -> transport.stop().blockingAwait(100, TimeUnit.SECONDS));
398398
assertEquals("Request has no handler: DELETE http://example.com", exception.getMessage());

0 commit comments

Comments
 (0)