Added separate cancellation tokens for TCP read operations

spotware · Jan 18, 2022 · fc1f813 · fc1f813
1 parent 6bce3c1
commit fc1f813
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 3 deletions.
diff --git a/src/OpenAPI.Net/OpenAPI.Net.csproj b/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>

diff --git a/src/OpenAPI.Net/OpenClient.cs b/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);