Updated use to naturally avoid nullable warnings.

Author: electricessence

Open.ChannelExtensions.ComparisonTests/Open.ChannelExtensions.ComparisonTests.csproj

@@ -1,8 +1,8 @@
-<Project Sdk="Microsoft.NET.Sdk">
+<Project Sdk="Microsoft.NET.Sdk">
 
   <PropertyGroup>
     <OutputType>Exe</OutputType>
-    <TargetFramework>netcoreapp3.0</TargetFramework>
+    <TargetFramework>net5.0</TargetFramework>
   </PropertyGroup>
 
   <ItemGroup>

Open.ChannelExtensions.Tests/BatchTests.cs

@@ -1,7 +1,5 @@
 using System;
-using System.Collections.Generic;
 using System.Diagnostics;
-using System.Linq;
 using System.Threading;
 using System.Threading.Channels;
 using System.Threading.Tasks;

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

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

Open.ChannelExtensions/BatchingChannelReader.cs

@@ -75,7 +75,7 @@ protected override bool TryPipeItems()
 					return true;
 				}
 
-				while (source.TryRead(out T item))
+				while (source.TryRead(out var item))
 				{
 					if (c == null) _batch = c = new List<T>(_batchSize) { item };
 					else c.Add(item);

Open.ChannelExtensions/BufferingChannelReader.cs

@@ -1,5 +1,4 @@
 using System;
-using System.Diagnostics;
 using System.Diagnostics.Contracts;
 using System.Threading;
 using System.Threading.Channels;
@@ -72,8 +71,11 @@ public override bool TryRead(out TOut item)
 		{
 			if (Buffer != null) do
 				{
-					if (Buffer.Reader.TryRead(out item))
+					if (Buffer.Reader.TryRead(out var i))
+					{
+						item = i;
 						return true;
+					}
 				}
 				while (TryPipeItems());
 

Open.ChannelExtensions/Extensions.Batch.cs

@@ -1,6 +1,4 @@
 using System;
-using System.Collections.Generic;
-using System.Diagnostics.Contracts;
 using System.Threading.Channels;
 
 namespace Open.ChannelExtensions

Open.ChannelExtensions/Extensions.Filter.cs

@@ -23,9 +23,11 @@ public FilteringChannelReader(ChannelReader<T> source, Func<T, bool> predicate)
 
 			public override bool TryRead(out T item)
 			{
-				while (_source.TryRead(out item))
+
+				while (_source.TryRead(out var i))
 				{
-					if (_predicate(item))
+					item = i;
+					if (_predicate(i))
 						return true;
 				}
 

Open.ChannelExtensions/Extensions.Join.cs

@@ -22,7 +22,7 @@ protected override bool TryPipeItems()
 
 				lock (Buffer)
 				{
-					if (!source.TryRead(out TList batch))
+					if (!source.TryRead(out var batch))
 						return false;
 
 					foreach (var i in batch)

Open.ChannelExtensions/Extensions.TypeFilter.cs

@@ -21,7 +21,7 @@ public TypeFilteringChannelReader(ChannelReader<TSource> source)
 
 			public override bool TryRead(out T item)
 			{
-				while (_source.TryRead(out TSource s))
+				while (_source.TryRead(out var s))
 				{
 					if (s is T i)
 					{