Update package version and fix ____KA____ stream (#52)

peter-quix · web-flow · commit 1128d7d35522 · 2023-03-02T12:38:57.000+01:00
* Fix ___KA___ keepalive key being raised as stream

* - Add some more logs for shutdown handling

- update to 0.5.0
diff --git a/src/CsharpClient/QuixStreams.ManyStreamTest/StreamingTest.cs b/src/CsharpClient/QuixStreams.ManyStreamTest/StreamingTest.cs
@@ -1,7 +1,6 @@
 ﻿using System;
 using System.Threading;
 using Microsoft.Extensions.Logging;
-using QuixStreams;
 using QuixStreams.Streaming;
 
 namespace QuixStreams.ManyStreamTest
diff --git a/src/CsharpClient/QuixStreams.PerformanceTest/PerformanceTest.cs b/src/CsharpClient/QuixStreams.PerformanceTest/PerformanceTest.cs
@@ -1,7 +1,7 @@
 ﻿using System;
 using System.Threading;
-using QuixStreams.Telemetry.Models;
 using QuixStreams.Streaming.UnitTests;
+using QuixStreams.Telemetry.Models;
 
 namespace QuixStreams.PerformanceTest
 {
diff --git a/src/CsharpClient/QuixStreams.PerformanceTest/WritePerformanceTest.cs b/src/CsharpClient/QuixStreams.PerformanceTest/WritePerformanceTest.cs
@@ -1,7 +1,7 @@
 ﻿using System;
 using System.Threading;
-using QuixStreams.Telemetry.Models.Utility;
 using QuixStreams.Streaming.Models;
+using QuixStreams.Telemetry.Models.Utility;
 
 namespace QuixStreams.PerformanceTest
 {
diff --git a/src/CsharpClient/QuixStreams.PerformanceTest/WritePerformanceTestQuix.cs b/src/CsharpClient/QuixStreams.PerformanceTest/WritePerformanceTestQuix.cs
@@ -1,8 +1,8 @@
 using System;
 using System.Threading;
-using QuixStreams.Telemetry.Models.Utility;
 using QuixStreams.Streaming;
 using QuixStreams.Streaming.Models;
+using QuixStreams.Telemetry.Models.Utility;
 
 namespace QuixStreams.PerformanceTest
 {
diff --git a/src/CsharpClient/QuixStreams.PerformanceTest/WritePerformanceTestRaw.cs b/src/CsharpClient/QuixStreams.PerformanceTest/WritePerformanceTestRaw.cs
@@ -1,9 +1,9 @@
 ﻿using System;
 using System.Collections.Generic;
 using System.Threading;
+using QuixStreams.Streaming.Models;
 using QuixStreams.Telemetry.Models;
 using QuixStreams.Telemetry.Models.Utility;
-using QuixStreams.Streaming.Models;
 
 namespace QuixStreams.PerformanceTest
 {
diff --git a/src/CsharpClient/QuixStreams.Speedtest/BufferTest.cs b/src/CsharpClient/QuixStreams.Speedtest/BufferTest.cs
@@ -2,9 +2,9 @@
 using System.Collections.Generic;
 using System.Linq;
 using System.Threading;
+using QuixStreams.Streaming;
 using QuixStreams.Telemetry.Models;
 using QuixStreams.Telemetry.Models.Utility;
-using QuixStreams.Streaming;
 
 namespace QuixStreams.Speedtest
 {
diff --git a/src/CsharpClient/QuixStreams.Speedtest/StreamingTestRaw.cs b/src/CsharpClient/QuixStreams.Speedtest/StreamingTestRaw.cs
@@ -2,8 +2,8 @@
 using System.Collections.Generic;
 using System.Linq;
 using System.Threading;
-using QuixStreams.Telemetry.Models;
 using QuixStreams.Streaming;
+using QuixStreams.Telemetry.Models;
 
 namespace QuixStreams.Speedtest
 {
diff --git a/src/CsharpClient/QuixStreams.State.ParallelWriteTest/Program.cs b/src/CsharpClient/QuixStreams.State.ParallelWriteTest/Program.cs
@@ -1,3 +1,7 @@
+using System;
+using System.Collections.Generic;
+using System.Threading;
+using System.Threading.Tasks;
 using QuixStreams.State.Storage;
 using QuixStreams.State.Storage.FileStorage.LocalFileStorage;
 
diff --git a/src/CsharpClient/QuixStreams.Streaming.IntegrationTests/StreamingClientIntegrationTests.cs b/src/CsharpClient/QuixStreams.Streaming.IntegrationTests/StreamingClientIntegrationTests.cs
@@ -5,10 +5,10 @@
 using System.Threading;
 using System.Threading.Tasks;
 using FluentAssertions;
+using Quix.TestBase.Extensions;
 using QuixStreams.Telemetry.Kafka;
 using QuixStreams.Telemetry.Models;
 using QuixStreams.Telemetry.Models.Utility;
-using Quix.TestBase.Extensions;
 using Xunit;
 using Xunit.Abstractions;
 
diff --git a/src/CsharpClient/QuixStreams.Streaming.IntegrationTests/StreamingRawIntegrationTests.cs b/src/CsharpClient/QuixStreams.Streaming.IntegrationTests/StreamingRawIntegrationTests.cs
@@ -1,8 +1,8 @@
 using System;
 using System.Collections.Generic;
 using System.Threading;
-using QuixStreams.Telemetry.Kafka;
 using Quix.TestBase.Extensions;
+using QuixStreams.Telemetry.Kafka;
 using Xunit;
 using Xunit.Abstractions;
 
diff --git a/src/CsharpClient/QuixStreams.Streaming.UnitTests/Models/StreamPropertiesProducerShould.cs b/src/CsharpClient/QuixStreams.Streaming.UnitTests/Models/StreamPropertiesProducerShould.cs
@@ -1,9 +1,8 @@
 using System.Threading;
 using System.Threading.Tasks;
 using NSubstitute;
-using QuixStreams;
-using QuixStreams.Streaming.Models.StreamProducer;
 using Quix.TestBase.Extensions;
+using QuixStreams.Streaming.Models.StreamProducer;
 using Xunit;
 using Xunit.Abstractions;
 
diff --git a/src/CsharpClient/QuixStreams.Streaming.UnitTests/Models/TimeseriesBufferShould.cs b/src/CsharpClient/QuixStreams.Streaming.UnitTests/Models/TimeseriesBufferShould.cs
@@ -2,8 +2,8 @@
 using System.Linq;
 using System.Threading;
 using FluentAssertions;
-using QuixStreams.Streaming.Models;
 using Quix.TestBase.Extensions;
+using QuixStreams.Streaming.Models;
 using Xunit;
 using Xunit.Abstractions;
 
diff --git a/src/CsharpClient/QuixStreams.Streaming.UnitTests/StreamingClientTests.cs b/src/CsharpClient/QuixStreams.Streaming.UnitTests/StreamingClientTests.cs
@@ -4,8 +4,8 @@
 using System.Text;
 using System.Threading;
 using FluentAssertions;
-using QuixStreams.Telemetry.Models;
 using Quix.TestBase.Extensions;
+using QuixStreams.Telemetry.Models;
 using Xunit;
 using Xunit.Abstractions;
 
diff --git a/src/CsharpClient/QuixStreams.Streaming/App.cs b/src/CsharpClient/QuixStreams.Streaming/App.cs
@@ -7,7 +7,6 @@
 using Microsoft.Extensions.Logging;
 using Mono.Unix;
 using Mono.Unix.Native;
-using QuixStreams;
 using QuixStreams.Streaming.Raw;
 
 namespace QuixStreams.Streaming
@@ -62,6 +61,7 @@ public static void Run(CancellationToken cancellationToken = default, Action bef
                 }
             };
 
+            logger.LogDebug("Setting up termination signal handling for {0}", Environment.OSVersion.Platform);
             switch (Environment.OSVersion.Platform)
             {
                 case PlatformID.Win32NT:
@@ -75,6 +75,7 @@ public static void Run(CancellationToken cancellationToken = default, Action bef
                     
                     AppDomain.CurrentDomain.ProcessExit += (sender, e) =>   
                     {
+                        logger.LogDebug("ProcessExit invoked");
                         // Don't unwind until main exits
                         waitForMainExit.Wait();
                     };                    
@@ -94,8 +95,10 @@ public static void Run(CancellationToken cancellationToken = default, Action bef
                         logger.LogDebug("Termination signal: {0}", signal.Signum);
                         waitForProcessShutdownStart.Set();
                     }, cancellationToken);
+                    
                     AppDomain.CurrentDomain.ProcessExit += (sender, e) =>
                     {
+                        logger.LogDebug("ProcessExit invoked");
                         // Don't unwind until main exits
                         waitForMainExit.Wait();
                     };
@@ -106,10 +109,12 @@ public static void Run(CancellationToken cancellationToken = default, Action bef
                 case PlatformID.Xbox:
                     Console.CancelKeyPress += (sender, args) =>
                     {
+                        logger.LogDebug("Termination signal: {0}", "CancelKeyPressEvent");
                         waitForProcessShutdownStart.Set();
                     };
                     AppDomain.CurrentDomain.ProcessExit += (sender, e) =>
                     {
+                        logger.LogDebug("ProcessExit invoked");
                         // We got a SIGTERM, signal that graceful shutdown has started
                         waitForProcessShutdownStart.Set();
                         
diff --git a/src/CsharpClient/QuixStreams.Streaming/IStreamConsumer.cs b/src/CsharpClient/QuixStreams.Streaming/IStreamConsumer.cs
@@ -1,6 +1,6 @@
 ﻿using System;
-using QuixStreams.Telemetry.Models;
 using QuixStreams.Streaming.Models.StreamConsumer;
+using QuixStreams.Telemetry.Models;
 
 namespace QuixStreams.Streaming
 {
diff --git a/src/CsharpClient/QuixStreams.Streaming/IStreamConsumerInternal.cs b/src/CsharpClient/QuixStreams.Streaming/IStreamConsumerInternal.cs
@@ -1,5 +1,4 @@
 ﻿using System;
-using QuixStreams;
 using QuixStreams.Telemetry.Models;
 
 namespace QuixStreams.Streaming
diff --git a/src/CsharpClient/QuixStreams.Streaming/KafkaStreamingClient.cs b/src/CsharpClient/QuixStreams.Streaming/KafkaStreamingClient.cs
@@ -1,13 +1,12 @@
 using System;
 using System.Collections.Generic;
 using Microsoft.Extensions.Logging;
-using QuixStreams;
-using QuixStreams.Telemetry.Configuration;
-using QuixStreams.Telemetry.Kafka;
-using QuixStreams.Telemetry.Models;
 using QuixStreams.Streaming.Configuration;
 using QuixStreams.Streaming.Models;
 using QuixStreams.Streaming.Raw;
+using QuixStreams.Telemetry.Configuration;
+using QuixStreams.Telemetry.Kafka;
+using QuixStreams.Telemetry.Models;
 using QuixStreams.Transport.Fw;
 
 namespace QuixStreams.Streaming
diff --git a/src/CsharpClient/QuixStreams.Streaming/Models/EventDefinition.cs b/src/CsharpClient/QuixStreams.Streaming/Models/EventDefinition.cs
@@ -1,6 +1,4 @@
-﻿using QuixStreams;
-
-namespace QuixStreams.Streaming.Models
+﻿namespace QuixStreams.Streaming.Models
 {
 
     /// <summary>
diff --git a/src/CsharpClient/QuixStreams.Streaming/Models/StreamProducer/StreamEventsProducer.cs b/src/CsharpClient/QuixStreams.Streaming/Models/StreamProducer/StreamEventsProducer.cs
@@ -3,11 +3,10 @@
 using System.Linq;
 using System.Threading;
 using Microsoft.Extensions.Logging;
-using QuixStreams;
+using QuixStreams.Streaming.Exceptions;
 using QuixStreams.Telemetry.Managers;
 using QuixStreams.Telemetry.Models;
 using QuixStreams.Telemetry.Models.Utility;
-using QuixStreams.Streaming.Exceptions;
 
 namespace QuixStreams.Streaming.Models.StreamProducer
 {
diff --git a/src/CsharpClient/QuixStreams.Streaming/Models/StreamProducer/StreamPropertiesProducer.cs b/src/CsharpClient/QuixStreams.Streaming/Models/StreamProducer/StreamPropertiesProducer.cs
@@ -4,7 +4,6 @@
 using System.Linq;
 using System.Threading;
 using Microsoft.Extensions.Logging;
-using QuixStreams;
 using QuixStreams.Telemetry.Models;
 
 namespace QuixStreams.Streaming.Models.StreamProducer
diff --git a/src/CsharpClient/QuixStreams.Streaming/Models/StreamProducer/StreamTimeseriesProducer.cs b/src/CsharpClient/QuixStreams.Streaming/Models/StreamProducer/StreamTimeseriesProducer.cs
@@ -2,10 +2,9 @@
 using System.Collections.Generic;
 using System.Threading;
 using Microsoft.Extensions.Logging;
-using QuixStreams;
+using QuixStreams.Streaming.Exceptions;
 using QuixStreams.Telemetry.Managers;
 using QuixStreams.Telemetry.Models.Utility;
-using QuixStreams.Streaming.Exceptions;
 
 namespace QuixStreams.Streaming.Models.StreamProducer
 {
diff --git a/src/CsharpClient/QuixStreams.Streaming/Models/StreamProducer/TimeseriesBufferProducer.cs b/src/CsharpClient/QuixStreams.Streaming/Models/StreamProducer/TimeseriesBufferProducer.cs
@@ -1,7 +1,7 @@
 ﻿using System;
 using System.Collections.Generic;
-using QuixStreams.Telemetry.Models.Utility;
 using QuixStreams.Streaming.Models.StreamConsumer;
+using QuixStreams.Telemetry.Models.Utility;
 
 namespace QuixStreams.Streaming.Models.StreamProducer
 {
diff --git a/src/CsharpClient/QuixStreams.Streaming/Models/TimeseriesBuffer.cs b/src/CsharpClient/QuixStreams.Streaming/Models/TimeseriesBuffer.cs
@@ -3,9 +3,8 @@
 using System.Linq;
 using System.Threading;
 using Microsoft.Extensions.Logging;
-using QuixStreams;
-using QuixStreams.Telemetry.Models;
 using QuixStreams.Streaming.Models.StreamConsumer;
+using QuixStreams.Telemetry.Models;
 
 namespace QuixStreams.Streaming.Models
 {
diff --git a/src/CsharpClient/QuixStreams.Streaming/Models/TimeseriesData.cs b/src/CsharpClient/QuixStreams.Streaming/Models/TimeseriesData.cs
@@ -1,9 +1,9 @@
 ﻿using System;
 using System.Collections.Generic;
 using System.Linq;
+using QuixStreams.Streaming.Utils;
 using QuixStreams.Telemetry.Models;
 using QuixStreams.Telemetry.Models.Utility;
-using QuixStreams.Streaming.Utils;
 
 namespace QuixStreams.Streaming.Models
 {
diff --git a/src/CsharpClient/QuixStreams.Streaming/Models/TimeseriesDataTimestamp.cs b/src/CsharpClient/QuixStreams.Streaming/Models/TimeseriesDataTimestamp.cs
@@ -1,7 +1,7 @@
 ﻿using System;
 using System.Collections.Generic;
-using QuixStreams.Telemetry.Models.Utility;
 using QuixStreams.Streaming.Utils;
+using QuixStreams.Telemetry.Models.Utility;
 
 namespace QuixStreams.Streaming.Models
 {
diff --git a/src/CsharpClient/QuixStreams.Streaming/QuixStreamingClient.cs b/src/CsharpClient/QuixStreams.Streaming/QuixStreamingClient.cs
@@ -15,8 +15,6 @@
 using System.Threading.Tasks;
 using Microsoft.Extensions.Logging;
 using Newtonsoft.Json;
-using QuixStreams;
-using QuixStreams.Telemetry.Kafka;
 using QuixStreams.Streaming.Configuration;
 using QuixStreams.Streaming.Exceptions;
 using QuixStreams.Streaming.Models;
@@ -25,6 +23,7 @@
 using QuixStreams.Streaming.QuixApi.Portal.Requests;
 using QuixStreams.Streaming.Raw;
 using QuixStreams.Streaming.Utils;
+using QuixStreams.Telemetry.Kafka;
 using QuixStreams.Transport.Fw;
 
 namespace QuixStreams.Streaming
diff --git a/src/CsharpClient/QuixStreams.Streaming/Raw/RawTopicConsumer.cs b/src/CsharpClient/QuixStreams.Streaming/Raw/RawTopicConsumer.cs
@@ -1,7 +1,6 @@
 ﻿using System;
 using System.Collections.Generic;
 using System.Collections.ObjectModel;
-using System.Text;
 using QuixStreams.Telemetry.Kafka;
 using QuixStreams.Transport.Kafka;
 
diff --git a/src/CsharpClient/QuixStreams.Streaming/Raw/RawTopicProducer.cs b/src/CsharpClient/QuixStreams.Streaming/Raw/RawTopicProducer.cs
@@ -1,6 +1,5 @@
 ﻿using System;
 using System.Collections.Generic;
-using System.Text;
 using QuixStreams.Transport.IO;
 using QuixStreams.Transport.Kafka;
 
diff --git a/src/CsharpClient/QuixStreams.Streaming/StreamConsumer.cs b/src/CsharpClient/QuixStreams.Streaming/StreamConsumer.cs
@@ -1,9 +1,8 @@
 ﻿using System;
 using Microsoft.Extensions.Logging;
-using QuixStreams;
+using QuixStreams.Streaming.Models.StreamConsumer;
 using QuixStreams.Telemetry;
 using QuixStreams.Telemetry.Models;
-using QuixStreams.Streaming.Models.StreamConsumer;
 
 namespace QuixStreams.Streaming
 {
diff --git a/src/CsharpClient/QuixStreams.Streaming/StreamProducer.cs b/src/CsharpClient/QuixStreams.Streaming/StreamProducer.cs
@@ -4,13 +4,12 @@
 using System.Linq;
 using System.Threading.Tasks;
 using Microsoft.Extensions.Logging;
-using QuixStreams;
+using QuixStreams.Streaming.Exceptions;
+using QuixStreams.Streaming.Models.StreamProducer;
 using QuixStreams.Telemetry;
 using QuixStreams.Telemetry.Kafka;
 using QuixStreams.Telemetry.Models;
 using QuixStreams.Telemetry.Models.Utility;
-using QuixStreams.Streaming.Exceptions;
-using QuixStreams.Streaming.Models.StreamProducer;
 
 namespace QuixStreams.Streaming
 {
diff --git a/src/CsharpClient/QuixStreams.Streaming/TopicConsumer.cs b/src/CsharpClient/QuixStreams.Streaming/TopicConsumer.cs
@@ -1,7 +1,6 @@
 ﻿using System;
 using System.Linq;
 using Microsoft.Extensions.Logging;
-using QuixStreams;
 using QuixStreams.Telemetry;
 using QuixStreams.Telemetry.Kafka;
 
diff --git a/src/CsharpClient/QuixStreams.Telemetry.Common.Test/TestTelemetryKafkaConsumer.cs b/src/CsharpClient/QuixStreams.Telemetry.Common.Test/TestTelemetryKafkaConsumer.cs
@@ -2,7 +2,6 @@
 using System.Collections.Generic;
 using System.Threading.Tasks;
 using Confluent.Kafka;
-using QuixStreams.Telemetry;
 using QuixStreams.Telemetry.Kafka;
 using QuixStreams.Transport.IO;
 using QuixStreams.Transport.Kafka;
diff --git a/src/CsharpClient/QuixStreams.Telemetry.UnitTests/KafkaReaderProducerShould.cs b/src/CsharpClient/QuixStreams.Telemetry.UnitTests/KafkaReaderProducerShould.cs
@@ -1,12 +1,10 @@
 using System;
 using System.Collections.Generic;
-using Microsoft.VisualStudio.TestPlatform.ObjectModel;
+using Quix.TestBase.Extensions;
 using QuixStreams.Telemetry.Common.Test;
 using QuixStreams.Telemetry.Kafka;
 using QuixStreams.Telemetry.Models;
 using QuixStreams.Telemetry.UnitTests.Helpers;
-using Quix.TestBase.Extensions;
-using QuixStreams.Telemetry;
 using Xunit;
 using Xunit.Abstractions;
 
diff --git a/src/CsharpClient/QuixStreams.Telemetry.UnitTests/StreamPipelineFactoryShould.cs b/src/CsharpClient/QuixStreams.Telemetry.UnitTests/StreamPipelineFactoryShould.cs
@@ -4,10 +4,9 @@
 using System.Linq;
 using FluentAssertions;
 using NSubstitute;
-using QuixStreams;
+using Quix.TestBase.Extensions;
 using QuixStreams.Telemetry.Models;
 using QuixStreams.Transport.IO;
-using Quix.TestBase.Extensions;
 using Xunit;
 using Xunit.Abstractions;
 
diff --git a/src/CsharpClient/QuixStreams.Telemetry.UnitTests/StreamProcessShould.cs b/src/CsharpClient/QuixStreams.Telemetry.UnitTests/StreamProcessShould.cs
@@ -1,6 +1,5 @@
 using System;
 using FluentAssertions;
-using QuixStreams.Telemetry;
 using QuixStreams.Telemetry.Models;
 using QuixStreams.Telemetry.UnitTests.Helpers;
 using Xunit;
diff --git a/src/CsharpClient/QuixStreams.Telemetry/Core/IOComponentConnection.cs b/src/CsharpClient/QuixStreams.Telemetry/Core/IOComponentConnection.cs
diff --git a/src/CsharpClient/QuixStreams.Telemetry/Core/StreamPipelineFactory.cs b/src/CsharpClient/QuixStreams.Telemetry/Core/StreamPipelineFactory.cs
diff --git a/src/CsharpClient/QuixStreams.Telemetry/Kafka/TelemetryKafkaProducer.cs b/src/CsharpClient/QuixStreams.Telemetry/Kafka/TelemetryKafkaProducer.cs
diff --git a/src/CsharpClient/QuixStreams.Transport.Kafka/Constants.cs b/src/CsharpClient/QuixStreams.Transport.Kafka/Constants.cs
diff --git a/src/CsharpClient/QuixStreams.Transport.Kafka/Extensions.cs b/src/CsharpClient/QuixStreams.Transport.Kafka/Extensions.cs
diff --git a/src/CsharpClient/QuixStreams.Transport.Kafka/KafkaConsumer.cs b/src/CsharpClient/QuixStreams.Transport.Kafka/KafkaConsumer.cs
diff --git a/src/CsharpClient/QuixStreams.Transport.Kafka/KafkaProducer.cs b/src/CsharpClient/QuixStreams.Transport.Kafka/KafkaProducer.cs
diff --git a/src/CsharpClient/QuixStreams.Transport.UnitTests/Fw/CommitModifierShould.cs b/src/CsharpClient/QuixStreams.Transport.UnitTests/Fw/CommitModifierShould.cs
diff --git a/src/CsharpClient/QuixStreams.Transport/Codec/Codec.cs b/src/CsharpClient/QuixStreams.Transport/Codec/Codec.cs
diff --git a/src/CsharpClient/QuixStreams.Transport/Fw/ByteSplittingModifier.cs b/src/CsharpClient/QuixStreams.Transport/Fw/ByteSplittingModifier.cs
diff --git a/src/CsharpClient/QuixStreams.Transport/Fw/CommitModifier.cs b/src/CsharpClient/QuixStreams.Transport/Fw/CommitModifier.cs
diff --git a/src/CsharpClient/QuixStreams.Transport/Fw/MergeBuffer.cs b/src/CsharpClient/QuixStreams.Transport/Fw/MergeBuffer.cs
diff --git a/src/PythonClient/setup.py b/src/PythonClient/setup.py
diff --git a/src/builds/csharp/nuget/build_nugets.py b/src/builds/csharp/nuget/build_nugets.py

Original file line number	Diff line number	Diff line change
`@@ -1,7 +1,7 @@`
`1`	`1`	`using System;`
`2`	`2`	`using System.Threading;`
`3`		`-using QuixStreams.Telemetry.Models;`
`4`	`3`	`using QuixStreams.Streaming.UnitTests;`
	`4`	`+using QuixStreams.Telemetry.Models;`
`5`	`5`
`6`	`6`	`namespace QuixStreams.PerformanceTest`
`7`	`7`	`{`
Original file line number	Diff line number	Diff line change
`@@ -1,8 +1,8 @@`
`1`	`1`	`using System;`
`2`	`2`	`using System.Threading;`
`3`		`-using QuixStreams.Telemetry.Models.Utility;`
`4`	`3`	`using QuixStreams.Streaming;`
`5`	`4`	`using QuixStreams.Streaming.Models;`
	`5`	`+using QuixStreams.Telemetry.Models.Utility;`
`6`	`6`
`7`	`7`	`namespace QuixStreams.PerformanceTest`
`8`	`8`	`{`
Original file line number	Diff line number	Diff line change
`@@ -2,8 +2,8 @@`
`2`	`2`	`using System.Collections.Generic;`
`3`	`3`	`using System.Linq;`
`4`	`4`	`using System.Threading;`
`5`		`-using QuixStreams.Telemetry.Models;`
`6`	`5`	`using QuixStreams.Streaming;`
	`6`	`+using QuixStreams.Telemetry.Models;`
`7`	`7`
`8`	`8`	`namespace QuixStreams.Speedtest`
`9`	`9`	`{`