Improvements.

Author: Oren (electricessence)

Extensions.Pipe.cs

@@ -9,6 +9,28 @@ namespace Open.Threading.Dataflow
 {
     public static partial class DataFlowExtensions
     {
+        /// <summary>
+        /// Pipes the source data to the target.
+        /// </summary>
+        /// <typeparam name="T">The input type.</typeparam>
+        /// <param name="source">The source block to receive from.</param>
+        /// <param name="transform">The target block to post to.</param>
+        /// <returns>The target block.</returns>
+        public static TBlock Pipe<T, TBlock>(this ISourceBlock<T> source,
+            TBlock target)
+            where TBlock : ITargetBlock<T>
+        {
+            if (source == null)
+                throw new NullReferenceException();
+            if (target == null)
+                throw new ArgumentNullException(nameof(target));
+            Contract.EndContractBlock();
+
+            source.LinkToWithCompletion(target);
+            return target;
+        }
+
+
         /// <summary>
         /// Produces a source block that contains transformed results.
         /// </summary>

Filters/AcceptOrPass.cs

@@ -52,7 +52,7 @@ public static partial class DataFlowExtensions
         /// <param name="source">The source block to receive from.</param>
         /// <param name="acceptor">The function to process the item and decide if accepted.</param>
         /// <returns>The original source block to allow for more acceptors or filters to be applied.</returns>
-        public static ISourceBlock<T> AcceptOrPass<T>(this ISourceBlock<T> source,
+        public static ISourceBlock<T> TakeOrContinue<T>(this ISourceBlock<T> source,
             Func<T, bool> acceptor)
         {
             var receiver = new AcceptOrPassBlock<T>(acceptor);

Open.Threading.Dataflow.csproj

@@ -15,10 +15,10 @@ Part of the "Open" set of libraries.</Description>
     <RepositoryUrl>https://github.com/electricessence/Open.Threading.Dataflow/</RepositoryUrl>
     <RepositoryType>git</RepositoryType>
     <PackageTags>dotnet, dotnet-core, dotnetcore, cs, dataflow, tpl, extensions</PackageTags>
-    <Version>2.1.2</Version>
+    <Version>2.2.0</Version>
     <PackageReleaseNotes></PackageReleaseNotes>
-    <AssemblyVersion>2.1.2.0</AssemblyVersion>
-    <FileVersion>2.1.2.0</FileVersion>
+    <AssemblyVersion>2.2.0.0</AssemblyVersion>
+    <FileVersion>2.2.0.0</FileVersion>
     <PackageLicenseExpression>MIT</PackageLicenseExpression>
   </PropertyGroup>