Corrected behavior so that a buffered channel reader doesn't fill up by default.

electricessence · electricessence · commit 2f02bf1ff6ec · 2021-10-07T23:30:28.000-07:00
diff --git a/Open.ChannelExtensions/BatchingChannelReader.cs b/Open.ChannelExtensions/BatchingChannelReader.cs
@@ -125,6 +125,9 @@ protected override bool TryPipeItems(bool flush)
 				if (!full) break;
 
 				Emit(ref c);
+
+				if (!flush)
+					goto finalizeTimer;
 			}
 
 			if (!flush || c is null)
diff --git a/Open.ChannelExtensions/Documentation.xml b/Open.ChannelExtensions/Documentation.xml
diff --git a/Open.ChannelExtensions/Open.ChannelExtensions.csproj b/Open.ChannelExtensions/Open.ChannelExtensions.csproj
@@ -20,8 +20,8 @@
 		<RepositoryUrl>https://github.com/Open-NET-Libraries/Open.ChannelExtensions</RepositoryUrl>
 		<RepositoryType>git</RepositoryType>
 		<GeneratePackageOnBuild>true</GeneratePackageOnBuild>
-		<Version>5.1.0</Version>
-		<PackageReleaseNotes>Added .WithTimeout(milliseconds) method for BatchChannelReader.</PackageReleaseNotes>
+		<Version>5.1.1</Version>
+		<PackageReleaseNotes></PackageReleaseNotes>
 		<PackageLicenseExpression>MIT</PackageLicenseExpression>
 		<PublishRepositoryUrl>true</PublishRepositoryUrl>
 		<IncludeSymbols>true</IncludeSymbols>

Original file line number	Diff line number	Diff line change
`@@ -125,6 +125,9 @@ protected override bool TryPipeItems(bool flush)`
`125`	`125`	`if (!full) break;`
`126`	`126`
`127`	`127`	`Emit(ref c);`
	`128`	`+`
	`129`	`+ if (!flush)`
	`130`	`+ goto finalizeTimer;`
`128`	`131`	`}`
`129`	`132`
`130`	`133`	`if (!flush \|\| c is null)`