Unit test cleanup.

Author: Jroland

src/kafka-tests/Unit/NagleBlockingCollectionTests.cs

@@ -195,7 +195,7 @@ public void TakeAsyncShouldPlayNiceWithTPL()
 
             dataTask.ContinueWith(x => exit = true);
 
-            Parallel.ForEach(Enumerable.Range(0, max),
+            Parallel.ForEach(Enumerable.Range(0, max).ToList(),
                    new ParallelOptions { MaxDegreeOfParallelism = 20 },
                    async x =>
                    {
@@ -228,7 +228,7 @@ public void TakeAsyncShouldBeThreadSafe()
             take3.ContinueWith(t => Console.WriteLine("Take3 done..."));
             Task.WhenAll(take1, take2, take3).ContinueWith(x => exit = true);
 
-            Parallel.ForEach(Enumerable.Range(0, max),
+            Parallel.ForEach(Enumerable.Range(0, max).ToList(),
                    new ParallelOptions { MaxDegreeOfParallelism = 20 },
                    async x =>
                    {

src/kafka-tests/Unit/ProducerTests.cs

@@ -84,7 +84,8 @@ public void ProducerShouldReportCorrectAmountOfAsyncRequests()
                 semaphore.Release();
                 sendTask.Wait(TimeSpan.FromMilliseconds(500));
 
-                Assert.That(producer.AsyncCount, Is.EqualTo(0), "Async should have completed.");
+                Assert.That(sendTask.IsCompleted, Is.True, "Send task should be marked as completed.");
+                Assert.That(producer.AsyncCount, Is.EqualTo(0), "Async should now show zero count.");
             }
         }