Fix issues with progress stream in jobs

Author: markcowl

src/Common/Commands.Common/AzureLongRunningJob.cs

@@ -80,6 +80,7 @@ protected AzureLongRunningJob(string command, string name) : base(command, name)
     /// <typeparam name="T">The type of the cmdlet being executed</typeparam>
     public class AzureLongRunningJob<T> : AzureLongRunningJob, ICommandRuntime where T : AzurePSCmdlet
     {
+        const int MaxRecords = 1000;
         string _status = "Running";
         T _cmdlet;
         ICommandRuntime _runtime;
@@ -671,7 +672,7 @@ public bool TransactionAvailable()
         public void WriteCommandDetail(string text)
         {
             ThrowIfJobFailedOrCancelled();
-            if (Verbose.IsOpen)
+            if (Verbose.IsOpen && Verbose.Count < MaxRecords)
             {
                 Verbose.Add(new VerboseRecord(text));
             }
@@ -684,7 +685,7 @@ public void WriteCommandDetail(string text)
         public void WriteDebug(string text)
         {
             ThrowIfJobFailedOrCancelled();
-            if (Debug.IsOpen)
+            if (Debug.IsOpen && Debug.Count < MaxRecords)
             {
                 Debug.Add(new DebugRecord(text));
             }
@@ -745,7 +746,7 @@ public void WriteObject(object sendToPipeline, bool enumerateCollection)
         public void WriteProgress(ProgressRecord progressRecord)
         {
             ThrowIfJobFailedOrCancelled();
-            if (Progress.IsOpen)
+            if (Progress.IsOpen && Progress.Count < MaxRecords)
             {
                 Progress.Add(progressRecord);
             }
@@ -769,7 +770,7 @@ public void WriteProgress(long sourceId, ProgressRecord progressRecord)
         public void WriteVerbose(string text)
         {
             ThrowIfJobFailedOrCancelled();
-            if (Verbose.IsOpen)
+            if (Verbose.IsOpen && Verbose.Count < MaxRecords)
             {
                 Verbose.Add(new VerboseRecord(text));
             }