Skip to content
This repository was archived by the owner on Dec 24, 2022. It is now read-only.
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
18 changes: 9 additions & 9 deletions src/ServiceStack.Redis/RedisNativeClient_Utils.cs
Original file line number Diff line number Diff line change
Expand Up @@ -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();
Expand All @@ -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();
Expand All @@ -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();
Expand All @@ -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();
Expand All @@ -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);
Expand All @@ -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();
Expand All @@ -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();
Expand All @@ -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();
Expand Down