Tweaks.

Author: Oren (electricessence)

Extensions.cs

@@ -218,18 +218,18 @@ Action onCompleted
 
 			public void OnNext(T value)
 			{
-				if (_onNext != null) _onNext(value);
-			}
+                _onNext?.Invoke(value);
+            }
 
 			public void OnError(Exception error)
 			{
-				if (_onError != null) _onError(error);
-			}
+                _onError?.Invoke(error);
+            }
 
 			public void OnCompleted()
 			{
-				if (_onCompleted != null) _onCompleted();
-			}
+                _onCompleted?.Invoke();
+            }
 
 
 			public void Dispose()

Open.Threading.Dataflow.csproj

@@ -17,4 +17,8 @@ Part of the "Open" set of libraries.</Description>
     <PackageTags>dotnet, dotnet-core, dotnetcore, cs, dataflow, tpl, extensions</PackageTags>
   </PropertyGroup>
 
+  <ItemGroup>
+    <PackageReference Include="Open.Threading" Version="1.0.1" />
+  </ItemGroup>
+
 </Project>