Commit e9a9f7a6 authored by Nick Craver's avatar Nick Craver

ChannelMessageQueue tests: await completion in others

parent 06cdae2b
...@@ -455,6 +455,7 @@ public async Task PubSubGetAllCorrectOrder_OnMessage_Sync() ...@@ -455,6 +455,7 @@ public async Task PubSubGetAllCorrectOrder_OnMessage_Sync()
} }
} }
await subChannel.Completion;
Assert.True(subChannel.IsCompleted); Assert.True(subChannel.IsCompleted);
await Assert.ThrowsAsync<ChannelClosedException>(async delegate await Assert.ThrowsAsync<ChannelClosedException>(async delegate
{ {
...@@ -515,6 +516,7 @@ public async Task PubSubGetAllCorrectOrder_OnMessage_Async() ...@@ -515,6 +516,7 @@ public async Task PubSubGetAllCorrectOrder_OnMessage_Async()
} }
} }
await subChannel.Completion;
Assert.True(subChannel.IsCompleted); Assert.True(subChannel.IsCompleted);
await Assert.ThrowsAsync<ChannelClosedException>(async delegate await Assert.ThrowsAsync<ChannelClosedException>(async delegate
{ {
......
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