Commit c22916bf authored by Nick Craver's avatar Nick Craver

Cleanup: RedisBatch

parent 78a5239b
...@@ -4,13 +4,11 @@ ...@@ -4,13 +4,11 @@
namespace StackExchange.Redis namespace StackExchange.Redis
{ {
class RedisBatch : RedisDatabase, IBatch internal class RedisBatch : RedisDatabase, IBatch
{ {
List<Message> pending; private List<Message> pending;
public RedisBatch(RedisDatabase wrapped, object asyncState) : base(wrapped.multiplexer, wrapped.Database, asyncState ?? wrapped.AsyncState) public RedisBatch(RedisDatabase wrapped, object asyncState) : base(wrapped.multiplexer, wrapped.Database, asyncState ?? wrapped.AsyncState) {}
{
}
public void Execute() public void Execute()
{ {
...@@ -93,6 +91,7 @@ internal override T ExecuteSync<T>(Message message, ResultProcessor<T> processor ...@@ -93,6 +91,7 @@ internal override T ExecuteSync<T>(Message message, ResultProcessor<T> processor
{ {
throw new NotSupportedException("ExecuteSync cannot be used inside a transaction"); throw new NotSupportedException("ExecuteSync cannot be used inside a transaction");
} }
private void FailNoServer(List<Message> messages) private void FailNoServer(List<Message> messages)
{ {
if (messages == null) return; if (messages == null) return;
...@@ -101,7 +100,6 @@ private void FailNoServer(List<Message> messages) ...@@ -101,7 +100,6 @@ private void FailNoServer(List<Message> messages)
{ {
msg.Fail(ConnectionFailureType.UnableToResolvePhysicalConnection, null); msg.Fail(ConnectionFailureType.UnableToResolvePhysicalConnection, null);
completion.CompleteSyncOrAsync(msg); completion.CompleteSyncOrAsync(msg);
} }
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment