If work is left finish that first

danielmarbach · danielmarbach · commit ea3c5c476a75 · 2020-03-26T08:43:25.000+01:00
diff --git a/projects/client/RabbitMQ.Client/src/client/impl/AsyncConsumerWorkService.cs b/projects/client/RabbitMQ.Client/src/client/impl/AsyncConsumerWorkService.cs
@@ -78,7 +78,7 @@ async Task Loop()
                         // Swallowing the task cancellation in case we are stopping work.
                     }
 
-                    while (_tokenSource.IsCancellationRequested == false && _workQueue.TryDequeue(out Work work))
+                    while (_workQueue.TryDequeue(out Work work))
                     {
                         await work.Execute(_model).ConfigureAwait(false);
                     }
diff --git a/projects/client/RabbitMQ.Client/src/client/impl/ConsumerWorkService.cs b/projects/client/RabbitMQ.Client/src/client/impl/ConsumerWorkService.cs
@@ -77,7 +77,7 @@ async Task Loop()
                         // Swallowing the task cancellation exception for the semaphore in case we are stopping.
                     }
 
-                    while (_tokenSource.IsCancellationRequested == false && _actions.TryDequeue(out Action action))
+                    while (_actions.TryDequeue(out Action action))
                     {
                         try
                         {

Original file line number	Diff line number	Diff line change
`@@ -78,7 +78,7 @@ async Task Loop()`
`78`	`78`	`// Swallowing the task cancellation in case we are stopping work.`
`79`	`79`	`}`
`80`	`80`
`81`		`- while (_tokenSource.IsCancellationRequested == false && _workQueue.TryDequeue(out Work work))`
	`81`	`+ while (_workQueue.TryDequeue(out Work work))`
`82`	`82`	`{`
`83`	`83`	`await work.Execute(_model).ConfigureAwait(false);`
`84`	`84`	`}`
Original file line number	Diff line number	Diff line change
`@@ -77,7 +77,7 @@ async Task Loop()`
`77`	`77`	`// Swallowing the task cancellation exception for the semaphore in case we are stopping.`
`78`	`78`	`}`
`79`	`79`
`80`		`- while (_tokenSource.IsCancellationRequested == false && _actions.TryDequeue(out Action action))`
	`80`	`+ while (_actions.TryDequeue(out Action action))`
`81`	`81`	`{`
`82`	`82`	`try`
`83`	`83`	`{`