Skip to content
This repository was archived by the owner on Dec 24, 2022. It is now read-only.

Commit 46ecd84

Browse files
committed
Allow IntCallbacks to be called if a long operation is queued
1 parent e6c7439 commit 46ecd84

File tree

2 files changed

+7
-4
lines changed

2 files changed

+7
-4
lines changed

src/ServiceStack.Redis/Pipeline/QueuedRedisOperation.cs

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -75,11 +75,15 @@ public void ProcessResult()
7575
else if (LongReadCommand != null)
7676
{
7777
var result = LongReadCommand();
78-
if (OnSuccessLongCallback != null)
78+
if (OnSuccessIntCallback != null)
79+
{
80+
OnSuccessIntCallback((int)result);
81+
}
82+
if (OnSuccessLongCallback != null)
7983
{
8084
OnSuccessLongCallback(result);
8185
}
82-
if (OnSuccessBoolCallback != null)
86+
if (OnSuccessBoolCallback != null)
8387
{
8488
var success = result == RedisNativeClient.Success;
8589
OnSuccessBoolCallback(success);

tests/ServiceStack.Redis.Tests/RedisPipelineTests.cs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -255,8 +255,8 @@ public void Pipeline_can_be_replayed()
255255
Assert.That(Redis.GetValue(Key), Is.EqualTo("1"));
256256
Assert.That(Redis.GetValue(KeySquared), Is.EqualTo("1"));
257257
}
258-
259258
}
259+
260260
[Test]
261261
public void Pipeline_can_be_contain_watch()
262262
{
@@ -273,7 +273,6 @@ public void Pipeline_can_be_contain_watch()
273273
Assert.That(Redis.GetValue(Key), Is.EqualTo("1"));
274274
Assert.That(Redis.GetValue(KeySquared), Is.EqualTo("1"));
275275
}
276-
277276
}
278277

279278
}

0 commit comments

Comments
 (0)