diff --git a/src/ServiceStack.Redis/RedisNativeClient_Utils.cs b/src/ServiceStack.Redis/RedisNativeClient_Utils.cs index b65150fd..7c747ab5 100644 --- a/src/ServiceStack.Redis/RedisNativeClient_Utils.cs +++ b/src/ServiceStack.Redis/RedisNativeClient_Utils.cs @@ -303,7 +303,7 @@ private int SafeReadByte() return Bstream.ReadByte(); } - private void SendExpectSuccess(params byte[][] cmdWithBinaryArgs) + protected void SendExpectSuccess(params byte[][] cmdWithBinaryArgs) { if (!SendCommand(cmdWithBinaryArgs)) throw CreateConnectionError(); @@ -316,7 +316,7 @@ private void SendExpectSuccess(params byte[][] cmdWithBinaryArgs) ExpectSuccess(); } - private int SendExpectInt(params byte[][] cmdWithBinaryArgs) + protected int SendExpectInt(params byte[][] cmdWithBinaryArgs) { if (!SendCommand(cmdWithBinaryArgs)) throw CreateConnectionError(); @@ -329,7 +329,7 @@ private int SendExpectInt(params byte[][] cmdWithBinaryArgs) return ReadInt(); } - private long SendExpectLong(params byte[][] cmdWithBinaryArgs) + protected long SendExpectLong(params byte[][] cmdWithBinaryArgs) { if (!SendCommand(cmdWithBinaryArgs)) throw CreateConnectionError(); @@ -342,7 +342,7 @@ private long SendExpectLong(params byte[][] cmdWithBinaryArgs) return ReadLong(); } - private byte[] SendExpectData(params byte[][] cmdWithBinaryArgs) + protected byte[] SendExpectData(params byte[][] cmdWithBinaryArgs) { if (!SendCommand(cmdWithBinaryArgs)) throw CreateConnectionError(); @@ -355,13 +355,13 @@ private byte[] SendExpectData(params byte[][] cmdWithBinaryArgs) return ReadData(); } - private string SendExpectString(params byte[][] cmdWithBinaryArgs) + protected string SendExpectString(params byte[][] cmdWithBinaryArgs) { var bytes = SendExpectData(cmdWithBinaryArgs); return bytes.FromUtf8Bytes(); } - private double SendExpectDouble(params byte[][] cmdWithBinaryArgs) + protected double SendExpectDouble(params byte[][] cmdWithBinaryArgs) { var bytes = SendExpectData(cmdWithBinaryArgs); return bytes == null ? Double.NaN : ParseDouble(bytes); @@ -377,7 +377,7 @@ public static double ParseDouble(byte[] doubleBytes) return d; } - private string SendExpectCode(params byte[][] cmdWithBinaryArgs) + protected string SendExpectCode(params byte[][] cmdWithBinaryArgs) { if (!SendCommand(cmdWithBinaryArgs)) throw CreateConnectionError(); @@ -391,7 +391,7 @@ private string SendExpectCode(params byte[][] cmdWithBinaryArgs) return ExpectCode(); } - private byte[][] SendExpectMultiData(params byte[][] cmdWithBinaryArgs) + protected byte[][] SendExpectMultiData(params byte[][] cmdWithBinaryArgs) { if (!SendCommand(cmdWithBinaryArgs)) throw CreateConnectionError(); @@ -404,7 +404,7 @@ private byte[][] SendExpectMultiData(params byte[][] cmdWithBinaryArgs) return ReadMultiData(); } - private object [] SendExpectDeeplyNestedMultiData(params byte[][] cmdWithBinaryArgs) + protected object[] SendExpectDeeplyNestedMultiData(params byte[][] cmdWithBinaryArgs) { if (!SendCommand(cmdWithBinaryArgs)) throw CreateConnectionError();