diff --git a/Sources/ZcashLightClientKit/Service/LightWalletGRPCService.swift b/Sources/ZcashLightClientKit/Service/LightWalletGRPCService.swift index b023a30d..3dbcfbbc 100644 --- a/Sources/ZcashLightClientKit/Service/LightWalletGRPCService.swift +++ b/Sources/ZcashLightClientKit/Service/LightWalletGRPCService.swift @@ -10,6 +10,7 @@ import Foundation import GRPC import NIO import NIOHPACK +import NIOTransportServices public typealias Channel = GRPC.GRPCChannel @@ -127,8 +128,8 @@ public class LightWalletGRPCService { self.singleCallTimeout = TimeLimit.timeout(.milliseconds(singleCallTimeout)) let connectionBuilder = secure ? - ClientConnection.usingPlatformAppropriateTLS(for: MultiThreadedEventLoopGroup(numberOfThreads: 1)) : - ClientConnection.insecure(group: MultiThreadedEventLoopGroup(numberOfThreads: 1)) + ClientConnection.usingPlatformAppropriateTLS(for: NIOTSEventLoopGroup(loopCount: 1, defaultQoS: .default)) : + ClientConnection.insecure(group: NIOTSEventLoopGroup(loopCount: 1, defaultQoS: .default)) let channel = connectionBuilder .withConnectivityStateDelegate(connectionManager, executingOn: queue) diff --git a/Tests/TestUtils/Tests+Utils.swift b/Tests/TestUtils/Tests+Utils.swift index 4d110bc1..d86f11e0 100644 --- a/Tests/TestUtils/Tests+Utils.swift +++ b/Tests/TestUtils/Tests+Utils.swift @@ -11,6 +11,7 @@ import GRPC import ZcashLightClientKit import XCTest import NIO +import NIOTransportServices enum Environment { static let lightwalletdKey = "LIGHTWALLETD_ADDRESS" @@ -40,8 +41,8 @@ class ChannelProvider { let endpoint = LightWalletEndpointBuilder.default let connectionBuilder = secure ? - ClientConnection.usingPlatformAppropriateTLS(for: MultiThreadedEventLoopGroup(numberOfThreads: 1)) : - ClientConnection.insecure(group: MultiThreadedEventLoopGroup(numberOfThreads: 1)) + ClientConnection.usingPlatformAppropriateTLS(for: NIOTSEventLoopGroup(loopCount: 1, defaultQoS: .default)) : + ClientConnection.insecure(group: NIOTSEventLoopGroup(loopCount: 1, defaultQoS: .default)) let channel = connectionBuilder .withKeepalive(