Fix Argument exception is thrown on dispose of consumer dispatcher (#1096)

Rotvig · Pliner · commit 0077d2efbbab · 2020-09-04T01:06:10.000+05:00
diff --git a/Source/EasyNetQ/Consumer/ConsumerDispatcher.cs b/Source/EasyNetQ/Consumer/ConsumerDispatcher.cs
@@ -24,10 +24,10 @@ public ConsumerDispatcher(ConnectionConfiguration configuration)
                     while (!cancellation.IsCancellationRequested)
                         try
                         {
-                            BlockingCollection<Action>.TakeFromAny(
-                                blockingCollections, out var action, cancellation.Token
-                            );
-                            action();
+                            if (BlockingCollection<Action>.TryTakeFromAny(blockingCollections, out var action, -1, cancellation.Token) >= 0)
+                            {
+                                action();
+                            }
                         }
                         catch (OperationCanceledException) when (cancellation.IsCancellationRequested)
                         {

Original file line number	Diff line number	Diff line change
`@@ -24,10 +24,10 @@ public ConsumerDispatcher(ConnectionConfiguration configuration)`
`24`	`24`	`while (!cancellation.IsCancellationRequested)`
`25`	`25`	`try`
`26`	`26`	`{`
`27`		`- BlockingCollection<Action>.TakeFromAny(`
`28`		`- blockingCollections, out var action, cancellation.Token`
`29`		`- );`
`30`		`- action();`
	`27`	`+ if (BlockingCollection<Action>.TryTakeFromAny(blockingCollections, out var action, -1, cancellation.Token) >= 0)`
	`28`	`+ {`
	`29`	`+ action();`
	`30`	`+ }`
`31`	`31`	`}`
`32`	`32`	`catch (OperationCanceledException) when (cancellation.IsCancellationRequested)`
`33`	`33`	`{`