Update reconnect attempt

Networking/Tests/NetworkingTests/MockPeerEventTests.swift

@@ -147,12 +147,16 @@ final class MockPeerEventTests {
             configuration: clientConfiguration
         )
 
-        // Attempt to connect
-        try clientConnection.connect(to: listenAddress)
-        let stream1 = try clientConnection.createStream()
-        try stream1.send(data: Data("test data 1".utf8))
+        do {
+            try clientConnection.connect(to: listenAddress)
+            let stream1 = try clientConnection.createStream()
+            try stream1.send(data: Data("test data 1".utf8))
+        } catch {
+            #expect(error != nil)
+            return
+        }
 
-        try? await Task.sleep(for: .milliseconds(100))
+        try await Task.sleep(for: .milliseconds(100))
         let (_, reason) = clientHandler.events.value.compactMap {
             switch $0 {
             case let .shutdownInitiated(connection, reason):
@@ -212,7 +216,7 @@ final class MockPeerEventTests {
         let stream1 = try clientConnection.createStream()
         try stream1.send(data: Data("test data 1".utf8))
 
-        try? await Task.sleep(for: .milliseconds(100))
+        try await Task.sleep(for: .milliseconds(100))
         let (_, info) = serverHandler.events.value.compactMap {
             switch $0 {
             case let .newConnection(_, connection, info):
@@ -266,14 +270,16 @@ final class MockPeerEventTests {
             registration: registration,
             configuration: clientConfiguration
         )
-
-        // Attempt to connect
-        try clientConnection.connect(to: listenAddress)
-        let stream1 = try clientConnection.createStream()
-        try stream1.send(data: Data("test data 1".utf8))
-
-        try? await Task.sleep(for: .milliseconds(100))
-        let (_, reason) = serverHandler.events.value.compactMap {
+        do {
+            try clientConnection.connect(to: listenAddress)
+            let stream1 = try clientConnection.createStream()
+            try stream1.send(data: Data("test data 1".utf8))
+        } catch {
+            #expect(error != nil)
+            return
+        }
+        try await Task.sleep(for: .milliseconds(100))
+        let (_, reason) = clientHandler.events.value.compactMap {
             switch $0 {
             case let .shutdownInitiated(connection, reason):
                 (connection, reason) as (QuicConnection, ConnectionCloseReason)?

Networking/Tests/NetworkingTests/PeerTests.swift

@@ -693,12 +693,9 @@ struct PeerTests {
         }
 
         var connections = [Connection<MockStreamHandler>]()
-        for i in 0 ..< peers.count {
+        for i in 0 ..< peersCount {
             let peer = peers[i]
-            for j in 0 ..< peers.count {
-                if i >= j {
-                    continue
-                }
+            for j in i + 1 ..< peersCount {
                 let otherPeer = peers[j]
                 let conn = try peer.connect(
                     to: otherPeer.listenAddress(),