Commit 0c0b9b6b authored by Marc Gravell's avatar Marc Gravell

TestPatternPubSub - ping before *and* after the publish

parent 0ebfbf40
......@@ -213,8 +213,9 @@ public async Task TestPatternPubSub()
Assert.Empty(received);
}
Assert.Equal(0, Thread.VolatileRead(ref secondHandler));
var count = sub.Publish("abc", "def");
await PingAsync(muxer, pub, sub).ForAwait();
var count = sub.Publish("abc", "def");
await PingAsync(muxer, pub, sub).ForAwait();
lock (received)
......
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