Merge branch 'master' into pipelines

StackExchange.Redis.Tests/Naming.cs

@@ -87,6 +87,8 @@ public void CheckDatabaseMethodsUseKeys(Type type)
                     case nameof(IDatabaseAsync.ExecuteAsync):
                     case nameof(IDatabase.ScriptEvaluate):
                     case nameof(IDatabaseAsync.ScriptEvaluateAsync):
+                    case nameof(IDatabase.StreamRead):
+                    case nameof(IDatabase.StreamReadAsync):
                         continue; // they're fine, but don't want to widen check to return type
                 }
 
@@ -214,7 +216,8 @@ private void CheckMethod(MethodInfo method, bool isAsync)
                     || shortName.StartsWith("Set")
                     || shortName.StartsWith("Script")
                     || shortName.StartsWith("SortedSet")
-                    || shortName.StartsWith("String") 
+                    || shortName.StartsWith("String")
+                    || shortName.StartsWith("Stream")
                     , fullName + ":Prefix");
             }
 

StackExchange.Redis.Tests/Streams.cs

 using System;
 using System.Linq;
+using System.Threading.Tasks;
 using Xunit;
 using Xunit.Abstractions;
 
@@ -481,7 +482,7 @@ public void StreamConsumerGroupViewPendingInfoSummary()
         }
 
         [Fact]
-        public void StreamConsumerGroupViewPendingMessageInfo()
+        public async Task StreamConsumerGroupViewPendingMessageInfo()
         {
             var key = GetUniqueKey("group_pending_messages");
             var groupName = "test_group";
@@ -507,6 +508,8 @@ public void StreamConsumerGroupViewPendingMessageInfo()
                 // Read the remaining messages into the second consumer.
                 var consumer2Messages = db.StreamReadGroup(key, groupName, consumer2);
 
+                await Task.Delay(10);
+
                 // Get the pending info about the messages themselves.
                 var pendingMessageInfoList = db.StreamPendingMessages(key, groupName, 10, RedisValue.Null);