Commit ed3e6e14 authored by Nick Craver's avatar Nick Craver

Tests: fix up PreserveOrder

parent 003aa073
...@@ -17,10 +17,11 @@ public void Execute() ...@@ -17,10 +17,11 @@ public void Execute()
using (var conn = Create()) using (var conn = Create())
{ {
var sub = conn.GetSubscriber(); var sub = conn.GetSubscriber();
var channel = Me();
var received = new List<int>(); var received = new List<int>();
Log("Subscribing..."); Log("Subscribing...");
const int COUNT = 1000; const int COUNT = 100;
sub.Subscribe("foo", (_, message) => sub.Subscribe(channel, (_, message) =>
{ {
lock (received) lock (received)
{ {
...@@ -42,7 +43,7 @@ public void Execute() ...@@ -42,7 +43,7 @@ public void Execute()
// it all goes to the server and back // it all goes to the server and back
for (int i = 0; i < COUNT; i++) for (int i = 0; i < COUNT; i++)
{ {
sub.Publish("foo", i); sub.Publish(channel, i);
} }
Log("Allowing time for delivery etc..."); Log("Allowing time for delivery etc...");
......
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