@@ -2583,14 +2583,14 @@ public void throwFromOnHandlerRunsAllHandlers() {
25832583 value2 .set (param1 );
25842584 }, String .class );
25852585
2586- hubConnection .start ().timeout (1 , TimeUnit .SECONDS ).blockingAwait ();
2586+ hubConnection .start ().timeout (30 , TimeUnit .SECONDS ).blockingAwait ();
25872587 mockTransport .receiveMessage ("{\" type\" :1,\" target\" :\" inc\" ,\" arguments\" :[\" Hello World\" ]}" + RECORD_SEPARATOR );
25882588
25892589 // Confirming that our handler was called and the correct message was passed in.
25902590 assertEquals ("Hello World" , value1 .get ());
25912591 assertEquals ("Hello World" , value2 .get ());
25922592
2593- hubConnection .stop ().timeout (1 , TimeUnit .SECONDS ).blockingAwait ();
2593+ hubConnection .stop ().timeout (30 , TimeUnit .SECONDS ).blockingAwait ();
25942594
25952595 ILoggingEvent log = logger .assertLog ("Invoking client side method 'inc' failed:" );
25962596 assertEquals ("throw from on handler" , log .getThrowableProxy ().getMessage ());
@@ -3189,10 +3189,10 @@ public void stopWithoutObservingWithLongPollingTransportStops() {
31893189 closed .onComplete ();
31903190 });
31913191
3192- hubConnection .start ().timeout (1 , TimeUnit .SECONDS ).blockingAwait ();
3192+ hubConnection .start ().timeout (30 , TimeUnit .SECONDS ).blockingAwait ();
31933193
31943194 hubConnection .stop ();
3195- closed .timeout (1 , TimeUnit .SECONDS ).blockingAwait ();
3195+ closed .timeout (30 , TimeUnit .SECONDS ).blockingAwait ();
31963196 blockGet .onComplete ();
31973197 assertEquals (HubConnectionState .DISCONNECTED , hubConnection .getConnectionState ());
31983198 }
@@ -3227,12 +3227,12 @@ public void hubConnectionClosesAndRunsOnClosedCallbackAfterCloseMessageWithLongP
32273227 hubConnection .onClosed ((ex ) -> {
32283228 closed .onComplete ();
32293229 });
3230- hubConnection .start ().timeout (1 , TimeUnit .SECONDS ).blockingAwait ();
3230+ hubConnection .start ().timeout (30 , TimeUnit .SECONDS ).blockingAwait ();
32313231
32323232 assertEquals (HubConnectionState .CONNECTED , hubConnection .getConnectionState ());
32333233 blockGet .onComplete ();
32343234
3235- closed .timeout (1 , TimeUnit .SECONDS ).blockingAwait ();
3235+ closed .timeout (30 , TimeUnit .SECONDS ).blockingAwait ();
32363236
32373237 assertEquals (HubConnectionState .DISCONNECTED , hubConnection .getConnectionState ());
32383238 }
0 commit comments