Fix for stream termination

Author: daveaglick

ReleaseNotes.md

@@ -1,5 +1,7 @@
 # 1.1.1
 
+- [Fix] Handles premature stream termination when reading events in the server
+
 # 1.1.0
 
 - [Feature] Support for server read cancellation with a `CancellationToken`

build.cake

@@ -85,9 +85,6 @@ Task("Restore")
         {
             MSBuildSettings = msBuildSettings
         });  
-        
-        // Run NuGet CLI restore to handle the Framework test projects       
-        NuGetRestore($"./{projectName}.sln"); 
     });
 
 Task("Build")
@@ -106,7 +103,7 @@ Task("Build")
 Task("Test")
     .Description("Runs all tests.")
     .IsDependentOn("Build")
-    .Does(() =>
+    .DoesForEach(GetFiles("./tests/*Tests/*.csproj"), project =>
     {
         DotNetCoreTestSettings testSettings = new DotNetCoreTestSettings()
         {
@@ -123,12 +120,10 @@ Task("Test")
             testSettings.TestAdapterPath = GetDirectories($"./tools/Appveyor.TestLogger.*/build/_common").First();
         }
 
-        foreach (var project in GetFiles("./tests/*Tests/*.csproj"))
-        {
-            Information($"Running tests in {project}");
-            DotNetCoreTest(MakeAbsolute(project).ToString(), testSettings);
-        }
-    });
+        Information($"Running tests in {project}");
+        DotNetCoreTest(MakeAbsolute(project).ToString(), testSettings);
+    })
+    .DeferOnError();
 
 Task("Pack")
     .Description("Packs the NuGet packages.")

src/MsBuildPipeLogger.Server/PipeLoggerServer.cs

@@ -81,12 +81,20 @@ public BuildEventArgs Read()
                 return null;
             }
 
-            BuildEventArgs args = _buildEventArgsReader.Read();
-            if (args != null)
+            try
             {
-                Dispatch(args);
-                return args;
+                BuildEventArgs args = _buildEventArgsReader.Read();
+                if (args != null)
+                {
+                    Dispatch(args);
+                    return args;
+                }
             }
+            catch(EndOfStreamException)
+            {
+                // The stream may have been closed or otherwise stopped
+            }
+
             return null;
         }