Commit 785b9612 authored by Marc Gravell's avatar Marc Gravell

make PubSubGetAllCorrectOrder less brittle

parent a6e99565
...@@ -349,7 +349,7 @@ public async Task PubSubGetAllCorrectOrder() ...@@ -349,7 +349,7 @@ public async Task PubSubGetAllCorrectOrder()
{ {
var sub = muxer.GetSubscriber(); var sub = muxer.GetSubscriber();
RedisChannel channel = Me(); RedisChannel channel = Me();
const int count = 1000; const int count = 250;
var syncLock = new object(); var syncLock = new object();
var data = new List<int>(count); var data = new List<int>(count);
...@@ -382,7 +382,7 @@ async Task RunLoop() ...@@ -382,7 +382,7 @@ async Task RunLoop()
Task.Run(RunLoop); Task.Run(RunLoop);
for (int i = 0; i < count; i++) for (int i = 0; i < count; i++)
{ {
sub.Publish(channel, i.ToString(), CommandFlags.FireAndForget); sub.Publish(channel, i.ToString());
if ((i % 100) == 99) Log("Published: " + i.ToString()); if ((i % 100) == 99) Log("Published: " + i.ToString());
} }
Log("Send loop complete."); Log("Send loop complete.");
......
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