Merge branch 'ssubscribe' into sharded-proposal

Author: mgravell

src/StackExchange.Redis/PhysicalConnection.cs

@@ -1697,18 +1697,21 @@ private void MatchResult(in RawResult result)
                     _readStatus = ReadStatus.PubSubPMessage;
 
                     var channel = items[2].AsRedisChannel(ChannelPrefix, RedisChannel.RedisChannelOptions.Pattern);
+
                     Trace("PMESSAGE: " + channel);
                     if (!channel.IsNull)
                     {
                         if (TryGetPubSubPayload(items[3], out var payload))
                         {
                             var sub = items[1].AsRedisChannel(ChannelPrefix, RedisChannel.RedisChannelOptions.Pattern);
+
                             _readStatus = ReadStatus.InvokePubSub;
                             muxer.OnMessage(sub, channel, payload);
                         }
                         else if (TryGetMultiPubSubPayload(items[3], out var payloads))
                         {
                             var sub = items[1].AsRedisChannel(ChannelPrefix, RedisChannel.RedisChannelOptions.Pattern);
+
                             _readStatus = ReadStatus.InvokePubSub;
                             muxer.OnMessage(sub, channel, payloads);
                         }

src/StackExchange.Redis/PublicAPI/PublicAPI.Shipped.txt

@@ -1315,7 +1315,9 @@ StackExchange.Redis.RedisChannel.PatternMode.Auto = 0 -> StackExchange.Redis.Red
 StackExchange.Redis.RedisChannel.PatternMode.Literal = 1 -> StackExchange.Redis.RedisChannel.PatternMode
 StackExchange.Redis.RedisChannel.PatternMode.Pattern = 2 -> StackExchange.Redis.RedisChannel.PatternMode
 StackExchange.Redis.RedisChannel.RedisChannel() -> void
+StackExchange.Redis.RedisChannel.RedisChannel(byte[]? value, bool isSharded) -> void
 StackExchange.Redis.RedisChannel.RedisChannel(byte[]? value, StackExchange.Redis.RedisChannel.PatternMode mode) -> void
+StackExchange.Redis.RedisChannel.RedisChannel(string! value, bool isSharded) -> void
 StackExchange.Redis.RedisChannel.RedisChannel(string! value, StackExchange.Redis.RedisChannel.PatternMode mode) -> void
 StackExchange.Redis.RedisCommandException
 StackExchange.Redis.RedisCommandException.RedisCommandException(string! message) -> void

src/StackExchange.Redis/RawResult.cs

@@ -174,6 +174,7 @@ internal RedisChannel AsRedisChannel(byte[]? channelPrefix, RedisChannel.RedisCh
                     if (StartsWith(channelPrefix))
                     {
                         byte[] copy = Payload.Slice(channelPrefix.Length).ToArray();
+
                         return new RedisChannel(copy, options);
                     }
                     return default;

src/StackExchange.Redis/RedisChannel.cs

@@ -9,6 +9,7 @@ namespace StackExchange.Redis
     public readonly struct RedisChannel : IEquatable<RedisChannel>
     {
         internal readonly byte[]? Value;
+        
         internal readonly RedisChannelOptions Options;
 
         [Flags]
@@ -36,6 +37,11 @@ internal enum RedisChannelOptions
         /// </summary>
         public bool IsSharded => (Options & RedisChannelOptions.Sharded) != 0;
 
+        /// <summary>
+        /// Indicates whether this channel represents a shard channel (see <c>SSUBSCRIBE</c>)
+        /// </summary>
+        public bool IsSharded => _isSharded;
+
         internal bool IsNull => Value == null;
 
         /// <summary>
@@ -313,4 +319,4 @@ public static implicit operator RedisChannel(byte[]? key)
         private RedisChannel(byte[]? value) => throw new NotSupportedException();
 #endif
     }
-}
+}