Avoid pre-cancelling concurrent operations. Allow errors to bubble up.

Author: Oren (electricessence)

Open.ChannelExtensions/Documentation.xml

@@ -101,7 +101,7 @@ public static ChannelReader<TOut> PipeAsync<TIn, TOut>(this ChannelReader<TIn> s
 				}, cancellationToken)
 				.ContinueWith(
 					t => writer.Complete(t.Exception),
-					cancellationToken,
+					CancellationToken.None,
 					TaskContinuationOptions.ExecuteSynchronously,
 					TaskScheduler.Current);
 

Open.ChannelExtensions/Extensions.Pipe.cs

@@ -42,7 +42,7 @@ public static Task<long> ReadAllConcurrentlyAsync<T>(this ChannelReader<T> reade
 				.WhenAll(readers)
 				.ContinueWith(
 					t => t.Result.Sum(),
-					cancellationToken,
+					CancellationToken.None,
 					TaskContinuationOptions.OnlyOnRanToCompletion | TaskContinuationOptions.ExecuteSynchronously,
 					TaskScheduler.Current);
 

Open.ChannelExtensions/Extensions.ReadConcurrently.cs

@@ -53,13 +53,13 @@ public static Task<long> WriteAllConcurrentlyAsync<T>(this ChannelWriter<T> targ
 
 						return t;
 					},
-					cancellationToken,
+					CancellationToken.None,
 					TaskContinuationOptions.ExecuteSynchronously,
 					TaskScheduler.Current)
 				.Unwrap()
 				.ContinueWith(
 					t => t.Result.Sum(),
-					cancellationToken,
+					CancellationToken.None,
 					TaskContinuationOptions.OnlyOnRanToCompletion | TaskContinuationOptions.ExecuteSynchronously,
 					TaskScheduler.Current);
 

Open.ChannelExtensions/Extensions.WriteConcurrently.cs

@@ -18,7 +18,7 @@
 		<RepositoryType>git</RepositoryType>
 		<PackageTags>channels dotnet threading tasks extensions</PackageTags>
 		<GeneratePackageOnBuild>true</GeneratePackageOnBuild>
-		<Version>3.2.2</Version>
+		<Version>3.2.3</Version>
 		<PackageLicenseExpression>MIT</PackageLicenseExpression>
 		<PackageReleaseNotes></PackageReleaseNotes>
 		<RepositoryUrl>https://github.com/electricessence/Open.ChannelExtensions</RepositoryUrl>