@@ -54,7 +54,7 @@ extension ValkeyClient {
54
54
process: ( ValkeySubscription ) async throws -> sending Value
55
55
) async throws -> Value {
56
56
try await self . subscribe (
57
- command: SUBSCRIBE ( channel : channels) ,
57
+ command: SUBSCRIBE ( channels : channels) ,
58
58
filters: channels. map { . channel( $0) } ,
59
59
process: process
60
60
)
@@ -98,7 +98,7 @@ extension ValkeyClient {
98
98
process: ( ValkeySubscription ) async throws -> sending Value
99
99
) async throws -> Value {
100
100
try await self . subscribe (
101
- command: PSUBSCRIBE ( pattern : patterns) ,
101
+ command: PSUBSCRIBE ( patterns : patterns) ,
102
102
filters: patterns. map { . pattern( $0) } ,
103
103
process: process
104
104
)
@@ -118,10 +118,10 @@ extension ValkeyClient {
118
118
/// - Returns: Return value of closure
119
119
@inlinable
120
120
public func ssubscribe< Value> (
121
- to shardchannel : String ... ,
121
+ to shardchannels : String ... ,
122
122
process: ( ValkeySubscription ) async throws -> sending Value
123
123
) async throws -> Value {
124
- try await self . ssubscribe ( to: shardchannel , process: process)
124
+ try await self . ssubscribe ( to: shardchannels , process: process)
125
125
}
126
126
127
127
/// Subscribe to list of shard channels and run closure with subscription
@@ -138,12 +138,12 @@ extension ValkeyClient {
138
138
/// - Returns: Return value of closure
139
139
@inlinable
140
140
public func ssubscribe< Value> (
141
- to shardchannel : [ String ] ,
141
+ to shardchannels : [ String ] ,
142
142
process: ( ValkeySubscription ) async throws -> sending Value
143
143
) async throws -> Value {
144
144
try await self . subscribe (
145
- command: SSUBSCRIBE ( shardchannel : shardchannel ) ,
146
- filters: shardchannel . map { . shardChannel( $0) } ,
145
+ command: SSUBSCRIBE ( shardchannels : shardchannels ) ,
146
+ filters: shardchannels . map { . shardChannel( $0) } ,
147
147
process: process
148
148
)
149
149
}
0 commit comments