Reformat and contract improvments.

Author: Oren (electricessence)

Extensions.cs

@@ -1,8 +1,8 @@
+using Open.Threading.Tasks;
 using System;
 using System.Linq;
 using System.Threading.Tasks;
 using System.Threading.Tasks.Dataflow;
-using Open.Threading.Tasks;
 
 namespace System.Threading.Tasks.Dataflow
 {
@@ -218,18 +218,18 @@ Action onCompleted
 
 			public void OnNext(T value)
 			{
-                _onNext?.Invoke(value);
-            }
+				_onNext?.Invoke(value);
+			}
 
 			public void OnError(Exception error)
 			{
-                _onError?.Invoke(error);
-            }
+				_onError?.Invoke(error);
+			}
 
 			public void OnCompleted()
 			{
-                _onCompleted?.Invoke();
-            }
+				_onCompleted?.Invoke();
+			}
 
 
 			public void Dispose()

Filters/AutoComplete.cs

@@ -1,10 +1,10 @@
+using Open.Threading;
 using System.Threading.Tasks.Dataflow;
-using Open.Threading;
 
 namespace Open.Dataflow
 {
 
-    internal class AutoCompleteFilter<T> : TargetBlockFilter<T>
+	internal class AutoCompleteFilter<T> : TargetBlockFilter<T>
 	{
 		public AutoCompleteFilter(int limit, ITargetBlock<T> target) : base(target)
 		{
@@ -47,4 +47,4 @@ public override DataflowMessageStatus OfferMessage(DataflowMessageHeader message
 		}
 	}
 
-}
+}

Filters/Changed.cs

@@ -1,9 +1,9 @@
+using Open.Threading;
 using System.Threading.Tasks.Dataflow;
-using Open.Threading;
 
 namespace Open.Dataflow
 {
-    internal class ChangedFilter<T> : TargetBlockFilter<T>
+	internal class ChangedFilter<T> : TargetBlockFilter<T>
 	{
 		readonly DataflowMessageStatus _defaultResponseForDuplicate;
 
@@ -25,4 +25,4 @@ public override DataflowMessageStatus OfferMessage(DataflowMessageHeader message
 				: _defaultResponseForDuplicate;
 		}
 	}
-}
+}

Filters/Distinct.cs

@@ -1,10 +1,10 @@
-using System.Collections.Generic;
+using System.Collections.Generic;
 using System.Threading.Tasks.Dataflow;
 
 namespace Open.Dataflow
 {
 
-    internal class DistinctFilter<T> : TargetBlockFilter<T>
+	internal class DistinctFilter<T> : TargetBlockFilter<T>
 	{
 		private readonly DataflowMessageStatus _defaultResponseForDuplicate;
 
@@ -28,4 +28,4 @@ public override DataflowMessageStatus OfferMessage(DataflowMessageHeader message
 		}
 	}
 
-}
+}

Open.Threading.Dataflow.csproj

@@ -30,7 +30,7 @@ Part of the "Open" set of libraries.</Description>
 
   <ItemGroup>
     <PackageReference Include="Open.Threading" Version="1.3.0" />
-    <PackageReference Include="Open.Threading.Tasks" Version="1.1.0" />
+    <PackageReference Include="Open.Threading.Tasks" Version="1.1.2" />
   </ItemGroup>
 
 </Project>

TargetBlockFilter.cs

@@ -1,11 +1,11 @@
-using System;
+using System;
 using System.Threading.Tasks;
 using System.Threading.Tasks.Dataflow;
 
 namespace Open.Dataflow
 {
 
-    internal abstract class TargetBlockFilter<T> : ITargetBlock<T>
+	internal abstract class TargetBlockFilter<T> : ITargetBlock<T>
 	{
 		protected readonly ITargetBlock<T> _target;
 
@@ -36,4 +36,4 @@ public void Fault(Exception exception)
 		public abstract DataflowMessageStatus OfferMessage(DataflowMessageHeader messageHeader, T messageValue, ISourceBlock<T> source, bool consumeToAccept);
 	}
 
-}
+}