Simplified async read operation as prefetching had no real benefit.

electricessence · electricessence · commit 0ef673b2a7fd · 2022-02-28T19:50:12.000-08:00
diff --git a/.editorconfig b/.editorconfig
@@ -1,3 +1,5 @@
+root = true
+
 # C# files
 [*.cs]
 
diff --git a/Open.ChannelExtensions/Documentation.xml b/Open.ChannelExtensions/Documentation.xml
diff --git a/Open.ChannelExtensions/Extensions.Read.cs b/Open.ChannelExtensions/Extensions.Read.cs
@@ -97,15 +97,12 @@ public static async ValueTask<long> ReadUntilCancelledAsync<T>(this ChannelReade
 		{
 			do
 			{
-				var next = new ValueTask();
 				while (
 					!cancellationToken.IsCancellationRequested
 					&& reader.TryRead(out T? item))
 				{
-					await next.ConfigureAwait(false);
-					next = receiver(item, index++);
+					await receiver(item, index++).ConfigureAwait(false);
 				}
-				await next.ConfigureAwait(false);
 			}
 			while (
 				!cancellationToken.IsCancellationRequested
diff --git a/Open.ChannelExtensions/Open.ChannelExtensions.csproj b/Open.ChannelExtensions/Open.ChannelExtensions.csproj
@@ -21,7 +21,7 @@
 		<RepositoryUrl>https://github.com/Open-NET-Libraries/Open.ChannelExtensions</RepositoryUrl>
 		<RepositoryType>git</RepositoryType>
 		<GeneratePackageOnBuild>true</GeneratePackageOnBuild>
-		<Version>6.0.0</Version>
+		<Version>6.0.1</Version>
 		<PackageReleaseNotes></PackageReleaseNotes>
 		<PackageLicenseExpression>MIT</PackageLicenseExpression>
 		<PublishRepositoryUrl>true</PublishRepositoryUrl>

Original file line number	Diff line number	Diff line change
`@@ -97,15 +97,12 @@ public static async ValueTask<long> ReadUntilCancelledAsync<T>(this ChannelReade`
`97`	`97`	`{`
`98`	`98`	`do`
`99`	`99`	`{`
`100`		`- var next = new ValueTask();`
`101`	`100`	`while (`
`102`	`101`	`!cancellationToken.IsCancellationRequested`
`103`	`102`	`&& reader.TryRead(out T? item))`
`104`	`103`	`{`
`105`		`- await next.ConfigureAwait(false);`
`106`		`- next = receiver(item, index++);`
	`104`	`+ await receiver(item, index++).ConfigureAwait(false);`
`107`	`105`	`}`
`108`		`- await next.ConfigureAwait(false);`
`109`	`106`	`}`
`110`	`107`	`while (`
`111`	`108`	`!cancellationToken.IsCancellationRequested`