Merge pull request #1015 from ricado-group/fixAsyncConsumerSemaphoreD…

…ispose Fix Semaphore Disposed Exception in AsyncConsumerWorkService
rabbitmq · Feb 5, 2021 · cff0c3d · cff0c3d
2 parents d39bb71 + 08854f1
commit cff0c3d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/projects/RabbitMQ.Client/client/impl/AsyncConsumerWorkService.cs b/projects/RabbitMQ.Client/client/impl/AsyncConsumerWorkService.cs
@@ -128,7 +128,7 @@ private async Task LoopWithConcurrency(CancellationToken cancellationToken)
                 {
                     while (await _channel.Reader.WaitToReadAsync(cancellationToken).ConfigureAwait(false))
                     {
-                        while (_channel.Reader.TryRead(out Work work))
+                        while (_channel.Reader.TryRead(out Work work) && !cancellationToken.IsCancellationRequested)
                         {
                             // Do a quick synchronous check before we resort to async/await with the state-machine overhead.
                             if (!_limiter.Wait(0))