moar fail

StackExchange.Redis.Tests/Parse.cs

@@ -13,8 +13,20 @@ public class Parse : TestBase
 
         public static IEnumerable<object[]> GetTestData()
         {
+            yield return new object[] { "$4\r\nPING\r\n$4\r\nPON", 1 };
+            yield return new object[] { "$4\r\nPING\r\n$4\r\nPONG", 1 };
+            yield return new object[] { "$4\r\nPING\r\n$4\r\nPONG\r", 1 };
             yield return new object[] { "$4\r\nPING\r\n$4\r\nPONG\r\n", 2 };
+            yield return new object[] { "$4\r\nPING\r\n$4\r\nPONG\r\n$4", 2 };
             yield return new object[] { "$4\r\nPING\r\n$4\r\nPONG\r\n$4\r", 2 };
+            yield return new object[] { "$4\r\nPING\r\n$4\r\nPONG\r\n$4\r\n", 2 };
+            yield return new object[] { "$4\r\nPING\r\n$4\r\nPONG\r\n$4\r\nP", 2 };
+            yield return new object[] { "$4\r\nPING\r\n$4\r\nPONG\r\n$4\r\nPO", 2 };
+            yield return new object[] { "$4\r\nPING\r\n$4\r\nPONG\r\n$4\r\nPON", 2 };
+            yield return new object[] { "$4\r\nPING\r\n$4\r\nPONG\r\n$4\r\nPONG", 2 };
+            yield return new object[] { "$4\r\nPING\r\n$4\r\nPONG\r\n$4\r\nPONG\r", 2 };
+            yield return new object[] { "$4\r\nPING\r\n$4\r\nPONG\r\n$4\r\nPONG\r\n", 3 };
+            yield return new object[] { "$4\r\nPING\r\n$4\r\nPONG\r\n$4\r\nPONG\r\n$", 3 };
         }
         [Theory]
         [MemberData(nameof(GetTestData))]

TestConsole/Program.cs

 using System;
+using System.Collections.Generic;
 using System.Diagnostics;
 using System.Runtime.CompilerServices;
 using System.Runtime.InteropServices;
@@ -22,7 +23,13 @@ private static void Main()
         }
         static ConnectionMultiplexer Create()
         {
-            var muxer = ConnectionMultiplexer.Connect("localhost:6379");
+            var options = new ConfigurationOptions
+            {
+                EndPoints = { "localhost:6379" },
+                SyncTimeout = int.MaxValue,
+                // CommandMap = CommandMap.Create(new HashSet<string> { "subscribe", "psubscsribe", "publish" }, false),
+            };
+            var muxer = ConnectionMultiplexer.Connect(options);
             muxer.GetDatabase().Ping();
             return muxer;
         }
@@ -82,7 +89,7 @@ private static void BatchRunPings(IDatabase db)
                 var batch = db.CreateBatch();
                 for (int j = 0; j < tasks.Length; j++)
                 {
-                    tasks[j] = batch.PingAsync();
+                    tasks[j] = batch.ExecuteAsync("echo", "echo" + j);
                 }
                 batch.Execute();
                 db.Multiplexer.WaitAll(tasks);