Cleanup and simplification.

Author: electricessence

Extensions.ActionBlock.cs

@@ -7,21 +7,21 @@ namespace Open.Threading.Dataflow
 	public static class ActionBlock
 	{
 		public static ActionBlock<T> New<T>(Action<T> action)
-			=> new ActionBlock<T>(action);
+			=> new(action);
 
 		public static ActionBlock<T> New<T>(Action<T> action, ExecutionDataflowBlockOptions options)
-			=> new ActionBlock<T>(action, options);
+			=> new(action, options);
 
 		public static ActionBlock<T> New<T>(Action<T> consumer, int maxParallel)
-		   => new ActionBlock<T>(consumer, new ExecutionDataflowBlockOptions() { MaxDegreeOfParallelism = maxParallel });
+		   => new(consumer, new ExecutionDataflowBlockOptions() { MaxDegreeOfParallelism = maxParallel });
 
 		public static ActionBlock<T> NewAsync<T>(Func<T, Task> action)
-			=> new ActionBlock<T>(action);
+			=> new(action);
 
 		public static ActionBlock<T> NewAsync<T>(Func<T, Task> action, ExecutionDataflowBlockOptions options)
-			=> new ActionBlock<T>(action, options);
+			=> new(action, options);
 
 		public static ActionBlock<T> NewAsync<T>(Func<T, Task> consumer, int maxParallel)
-			=> new ActionBlock<T>(consumer, new ExecutionDataflowBlockOptions() { MaxDegreeOfParallelism = maxParallel });
+			=> new(consumer, new ExecutionDataflowBlockOptions() { MaxDegreeOfParallelism = maxParallel });
 	}
 }

Filters/Changed.cs

@@ -9,7 +9,7 @@ public ChangedFilter(ITargetBlock<T> target, DataflowMessageStatus defaultRespon
 		{
 		}
 
-		readonly object SyncLock = new object();
+		readonly object SyncLock = new();
 		T _last = default!;
 
 		protected override bool Accept(T messageValue)

Filters/Distinct.cs

@@ -10,7 +10,7 @@ public DistinctFilter(ITargetBlock<T> target, DataflowMessageStatus defaultRespo
 		{
 		}
 
-		private readonly HashSet<T> _set = new HashSet<T>();
+		private readonly HashSet<T> _set = new();
 
 		protected override bool Accept(T messageValue)
 		{

Open.Threading.Dataflow.csproj

@@ -4,6 +4,7 @@
 		<TargetFrameworks>netstandard2.0;netstandard2.1</TargetFrameworks>
 		<LangVersion>latest</LangVersion>
 		<Nullable>enable</Nullable>
+		<EnableNETAnalyzers>true</EnableNETAnalyzers>
 		<GeneratePackageOnBuild>True</GeneratePackageOnBuild>
 		<Authors>electricessence</Authors>
 		<Description>