Skip to content

S
StackExchange.Redis
Commit 995e06b2 authored by Nick Craver's avatar Nick Craver
Browse files
Options

Tests: PubSub: MOAR LOGGING

parent 1ba99740
Hide whitespace changes
Inline Side-by-side
Showing with 12 additions and 0 deletions
StackExchange.Redis.Tests/PubSub.cs
View file @ 995e06b2
...@@ -396,12 +396,16 @@ async Task RunLoop() ...@@ -396,12 +396,16 @@ async Task RunLoop()
} }
} }
Log("Awaiting completion.");
await subChannel.Completion; await subChannel.Completion;
Log("Completion awaited.");
await Assert.ThrowsAsync<ChannelClosedException>(async delegate await Assert.ThrowsAsync<ChannelClosedException>(async delegate
{ {
var final = await subChannel.ReadAsync().ForAwait(); var final = await subChannel.ReadAsync().ForAwait();
}).ForAwait(); }).ForAwait();
Log("End of muxer.");
} }
Log("End of test.");
} }
[Fact] [Fact]
...@@ -455,13 +459,17 @@ public async Task PubSubGetAllCorrectOrder_OnMessage_Sync() ...@@ -455,13 +459,17 @@ public async Task PubSubGetAllCorrectOrder_OnMessage_Sync()
} }
} }
Log("Awaiting completion.");
await subChannel.Completion; await subChannel.Completion;
Log("Completion awaited.");
Assert.True(subChannel.Completion.IsCompleted); Assert.True(subChannel.Completion.IsCompleted);
await Assert.ThrowsAsync<ChannelClosedException>(async delegate await Assert.ThrowsAsync<ChannelClosedException>(async delegate
{ {
var final = await subChannel.ReadAsync().ForAwait(); var final = await subChannel.ReadAsync().ForAwait();
}).ForAwait(); }).ForAwait();
Log("End of muxer.");
} }
Log("End of test.");
} }
[Fact] [Fact]
...@@ -516,13 +524,17 @@ public async Task PubSubGetAllCorrectOrder_OnMessage_Async() ...@@ -516,13 +524,17 @@ public async Task PubSubGetAllCorrectOrder_OnMessage_Async()
} }
} }
Log("Awaiting completion.");
await subChannel.Completion; await subChannel.Completion;
Log("Completion awaited.");
Assert.True(subChannel.Completion.IsCompleted); Assert.True(subChannel.Completion.IsCompleted);
await Assert.ThrowsAsync<ChannelClosedException>(async delegate await Assert.ThrowsAsync<ChannelClosedException>(async delegate
{ {
var final = await subChannel.ReadAsync().ForAwait(); var final = await subChannel.ReadAsync().ForAwait();
}).ForAwait(); }).ForAwait();
Log("End of muxer.");
} }
Log("End of test.");
} }
[Fact] [Fact]
......
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