Simplfied and revised for testing branch.

Author: electricessence

Open.ChannelExtensions.Tests/BasicTests.cs

@@ -330,32 +330,4 @@ public static async Task Filter(int testSize)
 		Assert.Equal(count, result.Count);
 		Assert.True(result.SequenceEqual(range.Where(i => i % 2 == 1)));
 	}
-
-	[Fact]
-	public static void PossibleSourceLoadingIssue()
-	{
-		const int expectedCount = 10000000;
-		int count_ = 0;
-
-		var queue = new BlockingCollection<int>();
-		var processingTask = StartProcessingTask2(queue.GetConsumingEnumerable());
-
-		for (var i = 0; i < expectedCount; i++)
-			queue.Add(i);
-
-		queue.CompleteAdding();
-
-		processingTask.Wait();
-
-		Assert.Equal(expectedCount, count_);
-
-		Task StartProcessingTask2(IEnumerable<int> source)
-			=> Channel.CreateUnbounded<int>()
-				.Source(source, true)
-				.ReadAll(IncrementCount2)
-				.AsTask();
-
-		void IncrementCount2(int c)
-			=> Interlocked.Increment(ref count_);
-	}
 }

Open.ChannelExtensions.Tests/Open.ChannelExtensions.Tests.csproj

@@ -2,7 +2,7 @@
 
 	<PropertyGroup>
 		<OutputType>Exe</OutputType>
-		<TargetFrameworks>net472; net5.0;</TargetFrameworks>
+		<TargetFramework>net5.0;</TargetFramework>
 		<LangVersion>latest</LangVersion>
 		<IsPackable>false</IsPackable>
 	</PropertyGroup>

Open.ChannelExtensions.Tests/Program.cs

@@ -3,6 +3,6 @@
 internal class Program
 {
 #if NET472
-	public static void Main(string[] args) {}
+	public static void Main() {}
 #endif
 }

Open.ChannelExtensions.Tests/SpecialTests.cs

@@ -0,0 +1,53 @@
+using System;
+using System.Collections.Concurrent;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading;
+using System.Threading.Channels;
+using System.Threading.Tasks;
+using Xunit;
+using Xunit.Abstractions;
+
+namespace Open.ChannelExtensions.Tests;
+
+public class SpecialTests
+{
+	private readonly ITestOutputHelper output;
+
+	public SpecialTests(ITestOutputHelper outputHelper)
+	{
+		output = outputHelper;
+	}
+
+	[Fact]
+	public void PossibleSourceLoadingIssue()
+	{
+		const int expectedCount = 10000000;
+		int count_ = 0;
+
+		var queue = new BlockingCollection<int>();
+		var processingTask = StartProcessingTask2(queue.GetConsumingEnumerable());
+
+		Console.WriteLine("Starting to fill queue.");
+		for (var i = 0; i < expectedCount; i++)
+			queue.Add(i);
+
+		Console.WriteLine("Queue fill complete.");
+
+		queue.CompleteAdding();
+
+		processingTask.Wait();
+
+		Assert.Equal(expectedCount, count_);
+
+		Task StartProcessingTask2(IEnumerable<int> source)
+			=> Channel.CreateUnbounded<int>()
+				.Source(source, true)
+				.ReadAll(IncrementCount2)
+				.AsTask();
+
+		void IncrementCount2(int c)
+			=> Interlocked.Increment(ref count_);
+	}
+}