Added separate cancellation tokens for TCP read operations

Author: Ahmad Noman Musleh

src/OpenAPI.Net/OpenAPI.Net.csproj

@@ -9,7 +9,7 @@
     <PackageTags>cTrader, Open API, Spotware</PackageTags>
     <Description>A .NET RX library for Spotware Open API</Description>
     <PackageId>Spotware.OpenAPI.Net</PackageId>
-    <Version>1.3.7-rc0</Version>
+    <Version>1.3.7-rc1</Version>
     <Platforms>AnyCPU</Platforms>
     <Company>Spotware</Company>
     <Authors>Spotware</Authors>

src/OpenAPI.Net/OpenClient.cs

@@ -387,7 +387,9 @@ private async Task ReadTcp(CancellationToken cancellationToken)
                     {
                         var count = lengthArray.Length - readBytes;
 
-                        readBytes += await _sslStream.ReadAsync(lengthArray, readBytes, count, cancellationToken).ConfigureAwait(false);
+                        var cancellationTokenSource = new CancellationTokenSource(TimeSpan.FromSeconds(20));
+
+                        readBytes += await _sslStream.ReadAsync(lengthArray, readBytes, count, cancellationTokenSource.Token).ConfigureAwait(false);
                     }
                     while (readBytes < lengthArray.Length);
 
@@ -405,7 +407,9 @@ private async Task ReadTcp(CancellationToken cancellationToken)
                     {
                         var count = data.Length - readBytes;
 
-                        readBytes += await _sslStream.ReadAsync(data, readBytes, count, cancellationToken).ConfigureAwait(false);
+                        var cancellationTokenSource = new CancellationTokenSource(TimeSpan.FromSeconds(20));
+
+                        readBytes += await _sslStream.ReadAsync(data, readBytes, count, cancellationTokenSource.Token).ConfigureAwait(false);
                     }
                     while (readBytes < length);