Increase test timeouts to 5 seconds

Author: adam-fowler

Tests/MQTTNIOTests/MQTTNIOTests.swift

@@ -130,7 +130,7 @@ final class MQTTNIOTests: XCTestCase {
             expectation.fulfill()
         }
 
-        wait(for: [expectation], timeout: 1.0)
+        wait(for: [expectation], timeout: 5.0)
 
         XCTAssertFalse(client.isActive())
         try client.syncShutdownGracefully()
@@ -159,7 +159,7 @@ final class MQTTNIOTests: XCTestCase {
         try client.publish(to: "testMQTTPublishRetain", payload: payload, qos: .atLeastOnce, retain: true).wait()
         _ = try client.subscribe(to: [.init(topicFilter: "testMQTTPublishRetain", qos: .atLeastOnce)]).wait()
 
-        wait(for: [expectation], timeout: 2.0)
+        wait(for: [expectation], timeout: 5.0)
 
         try client.disconnect().wait()
         try client.syncShutdownGracefully()
@@ -193,7 +193,7 @@ final class MQTTNIOTests: XCTestCase {
         try client.publish(to: "testAtLeastOnce", payload: payload, qos: .atLeastOnce).wait()
         try client.publish(to: "testExactlyOnce", payload: payload, qos: .exactlyOnce).wait()
 
-        wait(for: [expectation], timeout: 2.0)
+        wait(for: [expectation], timeout: 5.0)
 
         try client.disconnect().wait()
         try client2.disconnect().wait()
@@ -230,7 +230,7 @@ final class MQTTNIOTests: XCTestCase {
         try client2.unsubscribe(from: ["testUnsubscribe"]).wait()
         try client.publish(to: "testUnsubscribe", payload: payload, qos: .atLeastOnce).wait()
 
-        wait(for: [expectation], timeout: 2.0)
+        wait(for: [expectation], timeout: 5.0)
 
         try client.disconnect().wait()
         try client2.disconnect().wait()
@@ -265,7 +265,7 @@ final class MQTTNIOTests: XCTestCase {
         _ = try client2.subscribe(to: [.init(topicFilter: "testLargeAtLeastOnce", qos: .atLeastOnce)]).wait()
         try client.publish(to: "testLargeAtLeastOnce", payload: payload, qos: .atLeastOnce).wait()
 
-        wait(for: [expectation], timeout: 2.0)
+        wait(for: [expectation], timeout: 5.0)
 
         try client.disconnect().wait()
         try client2.disconnect().wait()
@@ -361,7 +361,7 @@ final class MQTTNIOTests: XCTestCase {
         // should not receive previous publish on connect as this is a cleanSession
         _ = try client2.connect(cleanSession: true).wait()
 
-        wait(for: [expectation], timeout: 2.0)
+        wait(for: [expectation], timeout: 5.0)
 
         try client.disconnect().wait()
         try client2.disconnect().wait()

Tests/MQTTNIOTests/MQTTNIOv5Tests.swift

@@ -140,7 +140,7 @@ final class MQTTNIOv5Tests: XCTestCase {
 
         try client.publish(to: "testMQTTSubscribeFlags1", payload: payload, qos: .atLeastOnce, retain: false).wait()
 
-        wait(for: [expectation], timeout: 2)
+        wait(for: [expectation], timeout: 5)
 
         try client.disconnect().wait()
         try client.syncShutdownGracefully()
@@ -181,7 +181,7 @@ final class MQTTNIOv5Tests: XCTestCase {
             properties: [.contentType("application/json")]
         ).wait()
 
-        wait(for: [expectation], timeout: 2.0)
+        wait(for: [expectation], timeout: 5.0)
 
         try client.disconnect().wait()
         try client.syncShutdownGracefully()
@@ -218,7 +218,7 @@ final class MQTTNIOv5Tests: XCTestCase {
         XCTAssertEqual(unsub.reasons[1], .noSubscriptionExisted)
         try client.publish(to: "testUnsubscribe", payload: payload, qos: .atLeastOnce).wait()
 
-        wait(for: [expectation], timeout: 2.0)
+        wait(for: [expectation], timeout: 5.0)
 
         try client.disconnect().wait()
         try client2.disconnect().wait()
@@ -275,7 +275,7 @@ final class MQTTNIOv5Tests: XCTestCase {
         // should not receive previous publish on connect as this is a cleanSession
         _ = try client2.v5.connect(cleanStart: true).wait()
 
-        wait(for: [expectation], timeout: 2.0)
+        wait(for: [expectation], timeout: 5.0)
 
         try client.disconnect().wait()
         try client2.disconnect().wait()