Backport Java test fixes (#39290)

Author: BrennanConroy

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

@@ -71,7 +71,7 @@ public void StatusCode204StopsLongPollingTriggersOnClosed() {
 
         assertFalse(onClosedRan.get());
         transport.start("http://example.com").timeout(30, TimeUnit.SECONDS).blockingAwait();
-        assertTrue(block.blockingAwait(1, TimeUnit.SECONDS));
+        assertTrue(block.blockingAwait(30, TimeUnit.SECONDS));
         assertTrue(onClosedRan.get());
         assertFalse(transport.isActive());
     }
@@ -100,7 +100,7 @@ public void LongPollingFailsWhenReceivingUnexpectedErrorCode() {
         });
 
         transport.start("http://example.com").timeout(30, TimeUnit.SECONDS).blockingAwait();
-        assertTrue(blocker.blockingAwait(1, TimeUnit.SECONDS));
+        assertTrue(blocker.blockingAwait(30, TimeUnit.SECONDS));
         assertFalse(transport.isActive());
         assertTrue(onClosedRan.get());
     }
@@ -126,7 +126,6 @@ public void CanSetAndTriggerOnReceive() {
         assertTrue(onReceivedRan.get());
     }
 
-    @Disabled("https://github.com/dotnet/aspnetcore/issues/34563")
     @Test
     public void LongPollingTransportOnReceiveGetsCalled() {
         AtomicInteger requestCount = new AtomicInteger();
@@ -158,7 +157,7 @@ public void LongPollingTransportOnReceiveGetsCalled() {
         transport.setOnClose((error) -> {});
 
         transport.start("http://example.com").timeout(30, TimeUnit.SECONDS).blockingAwait();
-        assertTrue(block.blockingAwait(1,TimeUnit.SECONDS));
+        assertTrue(block.blockingAwait(30,TimeUnit.SECONDS));
         assertTrue(onReceiveCalled.get());
         assertEquals("TEST", message.get());
     }
@@ -203,7 +202,7 @@ public void LongPollingTransportOnReceiveGetsCalledMultipleTimes() {
         transport.setOnClose((error) -> {});
 
         transport.start("http://example.com").timeout(30, TimeUnit.SECONDS).blockingAwait();
-        assertTrue(blocker.blockingAwait(1, TimeUnit.SECONDS));
+        assertTrue(blocker.blockingAwait(30, TimeUnit.SECONDS));
         assertTrue(onReceiveCalled.get());
         assertEquals("FIRSTSECONDTHIRD", message.get());
     }
@@ -219,7 +218,7 @@ public void LongPollingTransportSendsHeaders() {
                         requestCount.incrementAndGet();
                         return Single.just(new HttpResponse(200, "", TestUtils.emptyByteBuffer));
                     }
-                    assertTrue(close.blockingAwait(1, TimeUnit.SECONDS));
+                    assertTrue(close.blockingAwait(30, TimeUnit.SECONDS));
                     return Single.just(new HttpResponse(204, "", TestUtils.emptyByteBuffer));
                 }).on("POST", (req) -> {
                     assertFalse(req.getHeaders().isEmpty());
@@ -234,7 +233,7 @@ public void LongPollingTransportSendsHeaders() {
 
         transport.start("http://example.com").timeout(30, TimeUnit.SECONDS).blockingAwait();
         ByteBuffer sendBuffer = TestUtils.stringToByteBuffer("TEST");
-        assertTrue(transport.send(sendBuffer).blockingAwait(1, TimeUnit.SECONDS));
+        assertTrue(transport.send(sendBuffer).blockingAwait(30, TimeUnit.SECONDS));
         close.onComplete();
         assertEquals(headerValue.get(), "VALUE");
     }
@@ -250,7 +249,7 @@ public void LongPollingTransportSetsAuthorizationHeader() {
                         requestCount.incrementAndGet();
                         return Single.just(new HttpResponse(200, "", TestUtils.emptyByteBuffer));
                     }
-                    assertTrue(close.blockingAwait(1, TimeUnit.SECONDS));
+                    assertTrue(close.blockingAwait(30, TimeUnit.SECONDS));
                     return Single.just(new HttpResponse(204, "", TestUtils.emptyByteBuffer));
                 })
                 .on("POST", (req) -> {
@@ -266,7 +265,7 @@ public void LongPollingTransportSetsAuthorizationHeader() {
 
         transport.start("http://example.com").timeout(30, TimeUnit.SECONDS).blockingAwait();
         ByteBuffer sendBuffer = TestUtils.stringToByteBuffer("TEST");
-        assertTrue(transport.send(sendBuffer).blockingAwait(1, TimeUnit.SECONDS));
+        assertTrue(transport.send(sendBuffer).blockingAwait(30, TimeUnit.SECONDS));
         assertEquals(headerValue.get(), "Bearer TOKEN");
         close.onComplete();
     }
@@ -285,7 +284,7 @@ public void LongPollingTransportRunsAccessTokenProviderEveryRequest() {
                     }
                     assertEquals("Bearer TOKEN1", req.getHeaders().get("Authorization"));
                     secondGet.onComplete();
-                    assertTrue(close.blockingAwait(1, TimeUnit.SECONDS));
+                    assertTrue(close.blockingAwait(30, TimeUnit.SECONDS));
                     return Single.just(new HttpResponse(204, "", TestUtils.emptyByteBuffer));
                 })
                 .on("POST", (req) -> {
@@ -301,9 +300,9 @@ public void LongPollingTransportRunsAccessTokenProviderEveryRequest() {
         transport.setOnClose((error) -> {});
 
         transport.start("http://example.com").timeout(30, TimeUnit.SECONDS).blockingAwait();
-        secondGet.blockingAwait(1, TimeUnit.SECONDS);
+        secondGet.blockingAwait(30, TimeUnit.SECONDS);
         ByteBuffer sendBuffer = TestUtils.stringToByteBuffer("TEST");
-        assertTrue(transport.send(sendBuffer).blockingAwait(1, TimeUnit.SECONDS));
+        assertTrue(transport.send(sendBuffer).blockingAwait(30, TimeUnit.SECONDS));
         assertEquals("Bearer TOKEN2", headerValue.get());
         close.onComplete();
     }
@@ -336,12 +335,12 @@ public void After204StopDoesNotTriggerOnCloseAgain() {
 
         assertFalse(onClosedRan.get());
         transport.start("http://example.com").timeout(30, TimeUnit.SECONDS).blockingAwait();
-        assertTrue(block.blockingAwait(1, TimeUnit.SECONDS));
+        assertTrue(block.blockingAwait(30, TimeUnit.SECONDS));
         assertEquals(1, onCloseCount.get());
         assertTrue(onClosedRan.get());
         assertFalse(transport.isActive());
 
-        assertTrue(transport.stop().blockingAwait(1, TimeUnit.SECONDS));
+        assertTrue(transport.stop().blockingAwait(30, TimeUnit.SECONDS));
         assertEquals(1, onCloseCount.get());
     }
 
@@ -355,7 +354,7 @@ public void StoppingTransportRunsCloseHandlersOnce() {
                         firstPoll.set(false);
                         return Single.just(new HttpResponse(200, "", TestUtils.emptyByteBuffer));
                     } else {
-                        assertTrue(block.blockingAwait(1, TimeUnit.SECONDS));
+                        assertTrue(block.blockingAwait(30, TimeUnit.SECONDS));
                         return Single.just(new HttpResponse(204, "", TestUtils.emptyByteBuffer));
                     }
                 })
@@ -374,7 +373,7 @@ public void StoppingTransportRunsCloseHandlersOnce() {
 
         assertEquals(0, onCloseCount.get());
         transport.start("http://example.com").timeout(30, TimeUnit.SECONDS).blockingAwait();
-        assertTrue(transport.stop().blockingAwait(1, TimeUnit.SECONDS));
+        assertTrue(transport.stop().blockingAwait(30, TimeUnit.SECONDS));
         assertEquals(1, onCloseCount.get());
         assertFalse(transport.isActive());
     }