Cleanup and version updates.

Author: Oren (electricessence)

Filters/AutoComplete.cs

@@ -8,21 +8,11 @@ internal class AutoCompleteFilter<T> : TargetBlockFilter<T>
 	{
 		public AutoCompleteFilter(int limit, ITargetBlock<T> target) : base(target)
 		{
-			_limit = limit;
-		}
-
-		private readonly int _limit;
-		public int Limit
-		{
-			get { return _limit; }
-		}
-
-		private int _allowed = 0;
-		public int AllowedCount
-		{
-			get { return _allowed; }
+			Limit = limit;
 		}
 
+		public int Limit { get; }
+		public int AllowedCount { get; private set; }
 
 
 		// The key here is to reject the message ahead of time.
@@ -32,12 +22,12 @@ public override DataflowMessageStatus OfferMessage(DataflowMessageHeader message
 			var completed = false;
 			// There are multiple operations happening here that require synchronization to get right.
 			ThreadSafety.LockConditional(_target,
-				() => _allowed < _limit,
+				() => AllowedCount < Limit,
 				() =>
 				{
-					_allowed++;
+					AllowedCount++;
 					result = _target.OfferMessage(messageHeader, messageValue, source, consumeToAccept);
-					completed = _allowed == _limit;
+					completed = AllowedCount == Limit;
 				}
 			);
 

Open.Threading.Dataflow.csproj

@@ -37,7 +37,7 @@ Part of the "Open" set of libraries.</Description>
   </ItemGroup>
 
   <ItemGroup>
-    <PackageReference Include="Open.Threading" Version="1.4.1" />
+    <PackageReference Include="Open.Threading" Version="1.4.2" />
     <PackageReference Include="Open.Threading.Tasks" Version="1.1.3" />
     <PackageReference Include="System.Threading.Tasks.Dataflow" Version="4.9.0" />
   </ItemGroup>