Commit 17f29411 authored by Nick Craver's avatar Nick Craver Committed by Nick Craver

Fix PubSub harder

parent c936eb01
......@@ -383,7 +383,7 @@ async Task RunLoop()
for (int i = 0; i < count; i++)
{
sub.Publish(channel, i.ToString(), CommandFlags.FireAndForget);
if ((i % 100) == 99) Log("Published: " + data.Count.ToString());
if ((i % 100) == 99) Log("Published: " + i.ToString());
}
Log("Send loop complete.");
if (!Monitor.Wait(syncLock, 20000))
......@@ -451,7 +451,7 @@ public async Task PubSubGetAllCorrectOrder_OnMessage_Sync()
for (int i = 0; i < count; i++)
{
sub.Publish(channel, i.ToString(), CommandFlags.FireAndForget);
if ((i % 100) == 99) Log("Published: " + data.Count.ToString());
if ((i % 100) == 99) Log("Published: " + i.ToString());
}
Log("Send loop complete.");
if (!Monitor.Wait(syncLock, 20000))
......@@ -521,7 +521,7 @@ public async Task PubSubGetAllCorrectOrder_OnMessage_Async()
for (int i = 0; i < count; i++)
{
sub.Publish(channel, i.ToString(), CommandFlags.FireAndForget);
if ((i % 100) == 99) Log("Published: " + data.Count.ToString());
if ((i % 100) == 99) Log("Published: " + i.ToString());
}
Log("Send loop complete.");
if (!Monitor.Wait(syncLock, 20000))
......
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