-fix PubSubChannels #151

2881099 · Jun 21, 2023 · 1b455b3 · 1b455b3
1 parent d01177c
commit 1b455b3
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/FreeRedis/IRedisClient.cs b/src/FreeRedis/IRedisClient.cs
@@ -184,7 +184,7 @@ public interface IRedisClient
         SubscribeListBroadcastObject SubscribeListBroadcast(string listKey, string clientId, Action<string> onMessage);
         SubscribeStreamObject SubscribeStream(string streamKey, Action<Dictionary<string, string>> onMessage);
         long Publish(string channel, string message);
-        string[] PubSubChannels(string pattern);
+        string[] PubSubChannels(string pattern = "*");
         long PubSubNumSub(string channel);
         long[] PubSubNumSub(string[] channels);
         long PubSubNumPat();
@@ -532,7 +532,7 @@ public interface IRedisClient
         Task<bool[]> JsonToggleAsync(string key, string path = "$");
         Task<string[]> JsonTypeAsync(string key, string path = "$");
         Task<long> PublishAsync(string channel, string message);
-        Task<string[]> PubSubChannelsAsync(string pattern);
+        Task<string[]> PubSubChannelsAsync(string pattern = "*");
         Task<long> PubSubNumSubAsync(string channel);
         Task<long[]> PubSubNumSubAsync(string[] channels);
         Task<long> PubSubNumPatAsync();

diff --git a/src/FreeRedis/RedisClient/PubSub.cs b/src/FreeRedis/RedisClient/PubSub.cs
@@ -37,7 +37,7 @@ partial class RedisClient
 #if isasync
         #region async (copy from sync)
         public Task<long> PublishAsync(string channel, string message) => CallAsync("PUBLISH".Input(channel, message), rt => rt.ThrowOrValue<long>());
-        public Task<string[]> PubSubChannelsAsync(string pattern) => CallAsync("PUBSUB".SubCommand("CHANNELS").Input(pattern), rt => rt.ThrowOrValue<string[]>());
+        public Task<string[]> PubSubChannelsAsync(string pattern = "*") => CallAsync("PUBSUB".SubCommand("CHANNELS").Input(pattern), rt => rt.ThrowOrValue<string[]>());
         public Task<long> PubSubNumSubAsync(string channel) => CallAsync("PUBSUB".SubCommand("NUMSUB").Input(channel), rt => rt.ThrowOrValue((a, _) => a.MapToList((x, y) => y.ConvertTo<long>()).FirstOrDefault()));
         public Task<long[]> PubSubNumSubAsync(string[] channels) => CallAsync("PUBSUB".SubCommand("NUMSUB").Input(channels), rt => rt.ThrowOrValue((a, _) => a.MapToList((x, y) => y.ConvertTo<long>()).ToArray()));
         public Task<long> PubSubNumPatAsync() => CallAsync("PUBLISH".SubCommand("NUMPAT"), rt => rt.ThrowOrValue<long>());
@@ -58,7 +58,7 @@ public IDisposable PSubscribe(string[] pattern, Action<string, object> handler)
         }
 
         public long Publish(string channel, string message) => Call("PUBLISH".Input(channel, message), rt => rt.ThrowOrValue<long>());
-        public string[] PubSubChannels(string pattern) => Call("PUBSUB".SubCommand("CHANNELS").Input(pattern), rt => rt.ThrowOrValue<string[]>());
+        public string[] PubSubChannels(string pattern = "*") => Call("PUBSUB".SubCommand("CHANNELS").Input(pattern), rt => rt.ThrowOrValue<string[]>());
         public long PubSubNumSub(string channel) => Call("PUBSUB".SubCommand("NUMSUB").Input(channel), rt => rt.ThrowOrValue((a, _) => a.MapToList((x, y) => y.ConvertTo<long>()).FirstOrDefault()));
         public long[] PubSubNumSub(string[] channels) => Call("PUBSUB".SubCommand("NUMSUB").Input(channels), rt => rt.ThrowOrValue((a, _) => a.MapToList((x, y) => y.ConvertTo<long>()).ToArray()));
         public long PubSubNumPat() => Call("PUBLISH".SubCommand("NUMPAT"), rt => rt.ThrowOrValue<long>());