Test improvements

Author: gjcairo

Tests/GRPCTests/ConnectionManagerTests.swift

@@ -1422,7 +1422,7 @@ extension ConnectionManagerTests {
   #if canImport(Network)
   func testDefaultChannelProvider_NWParametersConfigurator() throws {
     let counter = NIOLockedValueBox(0)
-    let group = NIOTSEventLoopGroup(loopCount: 1)
+    let group = NIOTSEventLoopGroup.singleton
     var configuration = ClientConnection.Configuration.default(
       target: .unixDomainSocket("/ignored"),
       eventLoopGroup: group
@@ -1460,8 +1460,6 @@ extension ConnectionManagerTests {
     try promise.futureResult.wait()
 
     XCTAssertEqual(1, counter.withLockedValue({ $0 }))
-
-    try group.syncShutdownGracefully()
   }
   #endif
 

Tests/GRPCTests/ConnectionPool/GRPCChannelPoolTests.swift

@@ -55,8 +55,22 @@ final class GRPCChannelPoolTests: GRPCTestCase {
     super.tearDown()
   }
 
-  private func configureEventLoopGroup(threads: Int = System.coreCount) {
-    self.group = MultiThreadedEventLoopGroup(numberOfThreads: threads)
+  private enum TestEventLoopGroupType {
+    case multiThreadedEventLoopGroup
+    case transportServicesEventLoopGroup
+  }
+
+  private func configureEventLoopGroup(
+    threads: Int = System.coreCount,
+    eventLoopGroupType: TestEventLoopGroupType = .multiThreadedEventLoopGroup
+  ) {
+    switch eventLoopGroupType {
+    case .multiThreadedEventLoopGroup:
+      self.group = MultiThreadedEventLoopGroup(numberOfThreads: threads)
+
+    case .transportServicesEventLoopGroup:
+      self.group = NIOTSEventLoopGroup(loopCount: threads)
+    }
   }
 
   private func makeServerBuilder(withTLS: Bool) -> Server.Builder {
@@ -627,7 +641,7 @@ final class GRPCChannelPoolTests: GRPCTestCase {
   #if canImport(Network)
   func testNWParametersConfigurator() {
     let counter = NIOLockedValueBox(0)
-    self.group = NIOTSEventLoopGroup()
+    self.configureEventLoopGroup(threads: 1, eventLoopGroupType: .transportServicesEventLoopGroup)
     self.startServer(withTLS: false)
     self.startChannel(withTLS: false) { configuration in
       configuration.transportServices.nwParametersConfigurator = { _ in

Tests/GRPCTests/ServerTests.swift

@@ -37,8 +37,10 @@ class ServerTests: GRPCTestCase {
       counter.withLockedValue { $0 += 1 }
     }
 
-    _ = try Server.start(configuration: serverConfiguration).wait()
+    let server = try Server.start(configuration: serverConfiguration).wait()
     XCTAssertEqual(1, counter.withLockedValue({ $0 }))
+
+    try? server.close().wait()
   }
   #endif
 }