update coverage

Networking/Sources/Networking/Peer.swift

@@ -603,7 +603,15 @@ private struct PeerEventHandler<Handler: StreamHandler>: QuicEventHandler {
                         impl.reopenUpStream(connection: connection, kind: kind)
                     }
                 }
+            } else {
+                logger.warning(
+                    "Stream closed but connection is gone?", metadata: ["streamId": "\(stream.id)"]
+                )
             }
+        } else {
+            logger.warning(
+                "Stream closed but stream is gone?", metadata: ["streamId": "\(quicStream.id)"]
+            )
         }
     }
 
@@ -617,7 +625,7 @@ private struct PeerEventHandler<Handler: StreamHandler>: QuicEventHandler {
         case .connectionIdle, .badCert:
             return false
         default:
-            return !status.isSucceeded
+            return status.isSucceeded
         }
     }
 }

Networking/Tests/NetworkingTests/PeerTests.swift

@@ -165,8 +165,8 @@ struct PeerTests {
             let con = try peer.connect(to: centerPeer.listenAddress(), role: .builder)
             try await con.ready()
         }
-        // Simulate close connections 3~5s
-        try? await Task.sleep(for: .milliseconds(5000))
+        // Simulate close connections 5~8s
+        try? await Task.sleep(for: .milliseconds(8000))
         centerPeer.broadcast(kind: .uniqueA, message: .init(kind: .uniqueA, data: Data("connection rotation strategy".utf8)))
         try? await Task.sleep(for: .milliseconds(1000))
         var receivedCount = 0
@@ -323,7 +323,7 @@ struct PeerTests {
         }
         stream!.close(abort: true)
         // Wait to simulate downtime & reopen up stream 3~5s
-        try? await Task.sleep(for: .milliseconds(3000))
+        try? await Task.sleep(for: .milliseconds(5000))
         messageData = Data("reopen up stream data".utf8)
         peer1.broadcast(
             kind: .uniqueA, message: .init(kind: .uniqueA, data: messageData)