@@ -92,14 +92,14 @@ public final class ValkeyClusterClient: Sendable {
9292 /// - nodeDiscovery: A ``ValkeyNodeDiscovery`` service that discovers Valkey nodes for the client in the cluster.
9393 /// - eventLoopGroup: The event loop group used for handling connections. Defaults to the global singleton.
9494 /// - logger: A logger for recording internal events and diagnostic information.
95- /// - connectionFactory : An overwrite to provide create your own underlying `Channel`s. Use this to wrap connections
96- /// in other NIO protocols (like SSH).
95+ /// - channelFactory : An overwrite to provide create your own underlying `Channel`s. Use this to wrap connections
96+ /// in other NIO protocols (like SSH).
9797 public init (
9898 clientConfiguration: ValkeyClientConfiguration ,
9999 nodeDiscovery: some ValkeyNodeDiscovery ,
100100 eventLoopGroup: EventLoopGroup = MultiThreadedEventLoopGroup . singleton,
101101 logger: Logger ,
102- connectionFactory : ( @Sendable ( ValkeyServerAddress , any EventLoop ) async throws -> any Channel ) ? = nil
102+ channelFactory : ( @Sendable ( ValkeyServerAddress , any EventLoop ) async throws -> any Channel ) ? = nil
103103 ) {
104104 self . logger = logger
105105 self . clientConfiguration = clientConfiguration
@@ -111,7 +111,7 @@ public final class ValkeyClusterClient: Sendable {
111111 configuration: clientConfiguration,
112112 connectionFactory: ValkeyConnectionFactory (
113113 configuration: clientConfiguration,
114- customHandler: connectionFactory
114+ customHandler: channelFactory
115115 ) ,
116116 eventLoopGroup: eventLoopGroup
117117 )
0 commit comments