Fixed test to use Task.Run.

Author: electricessence

Open.ChannelExtensions.Tests/SpecialTests.cs

@@ -8,10 +8,10 @@ public class SpecialTests
 	public async Task PossibleSourceLoadingIssue()
 	{
 		const int expectedCount = 10000000;
-		int count_ = 0;
+		int count = 0;
 
 		var queue = new BlockingCollection<int>();
-		var processingTask = StartProcessingTask2(queue.GetConsumingEnumerable());
+		var processingTask = Task.Run(()=> StartProcessingTask2(queue.GetConsumingEnumerable()));
 
 		Console.WriteLine("Starting to fill queue.");
 		for (var i = 0; i < expectedCount; i++)
@@ -23,7 +23,7 @@ public async Task PossibleSourceLoadingIssue()
 
 		await processingTask;
 
-		Assert.Equal(expectedCount, count_);
+		Assert.Equal(expectedCount, count);
 
 		Task StartProcessingTask2(IEnumerable<int> source)
 			=> Channel.CreateUnbounded<int>()
@@ -32,6 +32,6 @@ Task StartProcessingTask2(IEnumerable<int> source)
 				.AsTask();
 
 		void IncrementCount2(int _)
-			=> Interlocked.Increment(ref count_);
+			=> Interlocked.Increment(ref count);
 	}
 }