Updated references and version.

Nullability fixes.

Author: electricessence

Filters/AutoComplete.cs

@@ -15,7 +15,7 @@ public AutoCompleteFilter(int limit, ITargetBlock<T> target) : base(target)
 
 
 		// The key here is to reject the message ahead of time.
-		public override DataflowMessageStatus OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T> source, bool consumeToAccept)
+		public override DataflowMessageStatus OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept)
 		{
 			var result = DataflowMessageStatus.DecliningPermanently;
 			var completed = false;

Filters/Filter.cs

@@ -32,7 +32,7 @@ protected virtual bool Accept(T messageValue)
 			=> _filter!(messageValue);
 
 		public override DataflowMessageStatus OfferMessage(
-			DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T> source, bool consumeToAccept)
+			DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept)
 		{
 			if (!Accepting)
 				return DataflowMessageStatus.DecliningPermanently;

Open.Threading.Dataflow.csproj

@@ -14,10 +14,10 @@
 		</Description>
 		<PackageTags>dataflow;tpl;extensions</PackageTags>
 		<Copyright>© electricessence (Oren F.) All rights reserved.</Copyright>
-		<PackageProjectUrl>https://github.com/electricessence/Open.Threading.Dataflow/</PackageProjectUrl>
-		<RepositoryUrl>https://github.com/electricessence/Open.Threading.Dataflow/</RepositoryUrl>
+		<PackageProjectUrl>https://github.com/Open-NET-Libraries/Open.Threading.Dataflow/</PackageProjectUrl>
+		<RepositoryUrl>https://github.com/Open-NET-Libraries/Open.Threading.Dataflow/</RepositoryUrl>
 		<RepositoryType>git</RepositoryType>
-		<Version>2.4.0</Version>
+		<Version>2.5.1</Version>
 		<PackageReleaseNotes></PackageReleaseNotes>
 		<PackageLicenseExpression>MIT</PackageLicenseExpression>
 		<PublishRepositoryUrl>true</PublishRepositoryUrl>
@@ -40,9 +40,9 @@
 	</ItemGroup>
 
 	<ItemGroup>
-		<PackageReference Include="Open.Threading" Version="1.6.0" />
-		<PackageReference Include="Open.Threading.Tasks" Version="1.2.1" />
-		<PackageReference Include="System.Threading.Tasks.Dataflow" Version="4.11.1" />
+		<PackageReference Include="Open.Threading" Version="1.6.1" />
+		<PackageReference Include="Open.Threading.Tasks" Version="1.2.2" />
+		<PackageReference Include="System.Threading.Tasks.Dataflow" Version="5.0.0" />
 	</ItemGroup>
 
 </Project>

TargetBlockFilterBase.cs

@@ -42,7 +42,7 @@ public void Fault(Exception exception)
 
 		// The key here is to reject the message ahead of time.
 		public virtual DataflowMessageStatus OfferMessage(
-			DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T> source, bool consumeToAccept)
+			DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T>? source, bool consumeToAccept)
 			=> Accepting
 				? Target.OfferMessage(messageHeader, messageValue, source, consumeToAccept)
 				: DataflowMessageStatus.DecliningPermanently;