tidying up

Author: santisq

src/PSParallelPipeline/PSOutputStreams.cs

@@ -33,7 +33,7 @@ internal PSOutputStreams(Worker worker)
         SetStreamHandlers();
     }
 
-    internal void AddOutput(PSOutputData data) => OutputPipe.Add(data); //, Token);
+    internal void AddOutput(PSOutputData data) => OutputPipe.Add(data);
 
     private void SetStreamHandlers()
     {

src/PSParallelPipeline/RunspacePool.cs

@@ -98,7 +98,7 @@ private async Task ProcessAnyAsync()
     internal CancellationTokenRegistration RegisterCancellation(Action callback) =>
         Token.Register(callback);
 
-    internal async Task WaitOnCancel() => await Task.WhenAll(_tasks);
+    internal async Task WaitOnCancelAsync() => await Task.WhenAll(_tasks);
 
     public void Dispose()
     {

src/PSParallelPipeline/Worker.cs

@@ -79,14 +79,14 @@ private async Task Start()
         }
         catch
         {
-            await _runspacePool.WaitOnCancel();
+            await _runspacePool.WaitOnCancelAsync();
         }
     }
 
     public void Dispose()
     {
-        _inputQueue.Dispose();
         OutputStreams.Dispose();
+        _inputQueue.Dispose();
         _cts.Dispose();
         _runspacePool.Dispose();
         GC.SuppressFinalize(this);