Print task status upon cancellation for TestBasicRoundtripConcurrent …

…and TestBasicRoundtripConcurrentManyMessages
rabbitmq · May 23, 2024 · d95d06c · d95d06c
1 parent f500cd4
commit d95d06c
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/projects/Test/Integration/TestAsyncConsumer.cs b/projects/Test/Integration/TestAsyncConsumer.cs
@@ -69,6 +69,8 @@ public async Task TestBasicRoundtripConcurrent()
             var tokenSource = new CancellationTokenSource(WaitSpan);
             CancellationTokenRegistration ctsr = tokenSource.Token.Register(() =>
             {
+                _output.WriteLine("publish1SyncSource Status: {0}", publish1SyncSource.Task.Status);
+                _output.WriteLine("publish2SyncSource Status: {0}", publish2SyncSource.Task.Status);
                 publish1SyncSource.TrySetCanceled();
                 publish2SyncSource.TrySetCanceled();
             });
@@ -141,6 +143,9 @@ public async Task TestBasicRoundtripConcurrentManyMessages()
             var tokenSource = new CancellationTokenSource(WaitSpan);
             CancellationTokenRegistration ctsr = tokenSource.Token.Register(() =>
             {
+                _output.WriteLine("publish1SyncSource Status: {0}", publish1SyncSource.Task.Status);
+                _output.WriteLine("publish2SyncSource Status: {0}", publish2SyncSource.Task.Status);
+                _output.WriteLine("consumerSyncSource Status: {0}", consumerSyncSource.Task.Status);
                 publish1SyncSource.TrySetCanceled();
                 publish2SyncSource.TrySetCanceled();
                 consumerSyncSource.TrySetCanceled();