You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: pubnub-kotlin/pubnub-kotlin-impl/src/integrationTest/kotlin/com/pubnub/api/integration/SubscribeIntegrationTests.kt
+5-9Lines changed: 5 additions & 9 deletions
Original file line number
Diff line number
Diff line change
@@ -1371,14 +1371,13 @@ class SubscribeIntegrationTests : BaseIntegrationTest() {
1371
1371
val channelName02 = randomChannel()
1372
1372
val expectedMessage ="test_${randomValue()}"
1373
1373
1374
-
val connectedLatch =CountDownLatch(1)// Wait for first connection
1375
-
val subscriptionChangedLatch =CountDownLatch(1)// Wait for subscription changed event
1376
-
val messagesLatch =CountDownLatch(2)// Wait for both listeners to receive message
1374
+
val connectedLatch =CountDownLatch(1)
1375
+
val subscriptionChangedLatch =CountDownLatch(1)
1376
+
val messagesLatch =CountDownLatch(2)
1377
1377
1378
1378
val connectedEventCount =AtomicInteger(0)
1379
-
val subscriptionChangedCount =
1380
-
AtomicInteger(0) // status event emitted but no actual resubscribe when channels unchanged
1381
-
val subscribeHttpRequestCount =AtomicInteger(0) // Count actual HTTP subscribe requests
1379
+
val subscriptionChangedCount =AtomicInteger(0)
1380
+
val subscribeHttpRequestCount =AtomicInteger(0)
1382
1381
1383
1382
// Track messages received by each listener
1384
1383
val listenerAMessageCount =AtomicInteger(0)
@@ -1391,7 +1390,6 @@ class SubscribeIntegrationTests : BaseIntegrationTest() {
1391
1390
val networkRequestDetails = logMessage.message asLogMessageContent.NetworkRequest
1392
1391
if (networkRequestDetails.path.contains("/v2/subscribe/")) {
0 commit comments