@@ -118,17 +118,17 @@ extension ValkeyConnection {
118
118
/// pattern
119
119
///
120
120
/// - Parameters:
121
- /// - shardchannel : list of shard channels to subscribe to
121
+ /// - shardchannels : list of shard channels to subscribe to
122
122
/// - isolation: Actor isolation
123
123
/// - process: Closure that is called with subscription async sequence
124
124
/// - Returns: Return value of closure
125
125
@inlinable
126
126
public func ssubscribe< Value> (
127
- to shardchannel : String ... ,
127
+ to shardchannels : String ... ,
128
128
isolation: isolated ( any Actor ) ? = #isolation,
129
129
process: ( ValkeySubscription ) async throws -> sending Value
130
130
) async throws -> sending Value {
131
- try await self . ssubscribe ( to: shardchannel , process: process)
131
+ try await self . ssubscribe ( to: shardchannels , process: process)
132
132
}
133
133
134
134
/// Subscribe to list of shard channels and run closure with subscription
@@ -139,19 +139,19 @@ extension ValkeyConnection {
139
139
/// pattern
140
140
///
141
141
/// - Parameters:
142
- /// - shardchannel : list of shard channels to subscribe to
142
+ /// - shardchannels : list of shard channels to subscribe to
143
143
/// - isolation: Actor isolation
144
144
/// - process: Closure that is called with subscription async sequence
145
145
/// - Returns: Return value of closure
146
146
@inlinable
147
147
public func ssubscribe< Value> (
148
- to shardchannel : [ String ] ,
148
+ to shardchannels : [ String ] ,
149
149
isolation: isolated ( any Actor ) ? = #isolation,
150
150
process: ( ValkeySubscription ) async throws -> sending Value
151
151
) async throws -> sending Value {
152
152
try await self . subscribe (
153
- command: SSUBSCRIBE ( shardchannels: shardchannel ) ,
154
- filters: shardchannel . map { . shardChannel( $0) } ,
153
+ command: SSUBSCRIBE ( shardchannels: shardchannels ) ,
154
+ filters: shardchannels . map { . shardChannel( $0) } ,
155
155
isolation: isolation,
156
156
process: process
157
157
)
0 commit comments