From e50610ecf246823c22d9d490d6a63d61c7a7b92a Mon Sep 17 00:00:00 2001 From: Luke Bakken Date: Thu, 20 Jun 2024 08:10:52 -0700 Subject: [PATCH] fixup --- .../client/impl/ConsumerDispatching/AsyncConsumerDispatcher.cs | 2 +- .../client/impl/ConsumerDispatching/ConsumerDispatcher.cs | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/projects/RabbitMQ.Client/client/impl/ConsumerDispatching/AsyncConsumerDispatcher.cs b/projects/RabbitMQ.Client/client/impl/ConsumerDispatching/AsyncConsumerDispatcher.cs index f5762c6f70..b96ef1bbfc 100644 --- a/projects/RabbitMQ.Client/client/impl/ConsumerDispatching/AsyncConsumerDispatcher.cs +++ b/projects/RabbitMQ.Client/client/impl/ConsumerDispatching/AsyncConsumerDispatcher.cs @@ -53,7 +53,7 @@ protected override async Task ProcessChannelAsync() } catch (OperationCanceledException) { - if (!_reader.Completion.IsCompleted) + if (false == _reader.Completion.IsCompleted) { throw; } diff --git a/projects/RabbitMQ.Client/client/impl/ConsumerDispatching/ConsumerDispatcher.cs b/projects/RabbitMQ.Client/client/impl/ConsumerDispatching/ConsumerDispatcher.cs index 6d62950791..dd7ba9b081 100644 --- a/projects/RabbitMQ.Client/client/impl/ConsumerDispatching/ConsumerDispatcher.cs +++ b/projects/RabbitMQ.Client/client/impl/ConsumerDispatching/ConsumerDispatcher.cs @@ -59,7 +59,7 @@ await consumer.HandleBasicDeliverAsync( } catch (OperationCanceledException) { - if (!_reader.Completion.IsCompleted) + if (false == _reader.Completion.IsCompleted) { throw; }