Fix review comments

Pliner · Pliner · commit 60ab92db8c75 · 2020-09-04T23:38:14.000+05:00
diff --git a/Source/EasyNetQ/Consumer/ConsumerDispatcher.cs b/Source/EasyNetQ/Consumer/ConsumerDispatcher.cs
@@ -24,7 +24,7 @@ public ConsumerDispatcher(ConnectionConfiguration configuration)
                     while (!cancellation.IsCancellationRequested)
                         try
                         {
-                            if (BlockingCollection<Action>.TryTakeFromAny(blockingCollections, out var action, -1, cancellation.Token) >= 0)
+                            if (BlockingCollection<Action>.TryTakeFromAny(blockingCollections, out var action, Timeout.Infinite, cancellation.Token) >= 0)
                             {
                                 action();
                             }
diff --git a/Source/EasyNetQ/Producer/ClientCommandDispatcherSingleton.cs b/Source/EasyNetQ/Producer/ClientCommandDispatcherSingleton.cs
@@ -101,8 +101,10 @@ private void StartDispatcherThread(ConnectionConfiguration configuration)
                 {
                     try
                     {
-                        if (queue.TryTake(out var channelAction, -1, cancellation.Token))
+                        if (queue.TryTake(out var channelAction, Timeout.Infinite, cancellation.Token))
+                        {
                             channelAction();
+                        }
                     }
                     catch (OperationCanceledException) when (cancellation.IsCancellationRequested)
                     {

Original file line number	Diff line number	Diff line change
`@@ -24,7 +24,7 @@ public ConsumerDispatcher(ConnectionConfiguration configuration)`
`24`	`24`	`while (!cancellation.IsCancellationRequested)`
`25`	`25`	`try`
`26`	`26`	`{`
`27`		`- if (BlockingCollection<Action>.TryTakeFromAny(blockingCollections, out var action, -1, cancellation.Token) >= 0)`
	`27`	`+ if (BlockingCollection<Action>.TryTakeFromAny(blockingCollections, out var action, Timeout.Infinite, cancellation.Token) >= 0)`
`28`	`28`	`{`
`29`	`29`	`action();`
`30`	`30`	`}`
Original file line number	Diff line number	Diff line change
`@@ -101,8 +101,10 @@ private void StartDispatcherThread(ConnectionConfiguration configuration)`
`101`	`101`	`{`
`102`	`102`	`try`
`103`	`103`	`{`
`104`		`- if (queue.TryTake(out var channelAction, -1, cancellation.Token))`
	`104`	`+ if (queue.TryTake(out var channelAction, Timeout.Infinite, cancellation.Token))`
	`105`	`+ {`
`105`	`106`	`channelAction();`
	`107`	`+ }`
`106`	`108`	`}`
`107`	`109`	`catch (OperationCanceledException) when (cancellation.IsCancellationRequested)`
`108`	`110`	`{`