Added another check to TCP read method

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-rc14</Version>
+    <Version>1.3.7</Version>
     <Platforms>AnyCPU</Platforms>
     <Company>Spotware</Company>
     <Authors>Spotware</Authors>

src/OpenAPI.Net/OpenClient.cs

@@ -272,6 +272,8 @@ public void Dispose()
 
             _messagesChannel.Writer.TryComplete();
 
+            _cancellationTokenSource.Dispose();
+
             MessagesQueueCount = 0;
 
             if (IsUsingWebSocket)
@@ -390,6 +392,8 @@ private async Task ReadTcp(CancellationToken cancellationToken)
                         var count = lengthArray.Length - readBytes;
 
                         readBytes += await _sslStream.ReadAsync(lengthArray, readBytes, count, cancellationToken).ConfigureAwait(false);
+
+                        if (readBytes == 0) new InvalidOperationException("Remote host closed the connection");
                     }
                     while (readBytes < lengthArray.Length);
 
@@ -408,6 +412,8 @@ private async Task ReadTcp(CancellationToken cancellationToken)
                         var count = data.Length - readBytes;
 
                         readBytes += await _sslStream.ReadAsync(data, readBytes, count, cancellationToken).ConfigureAwait(false);
+
+                        if (readBytes == 0) new InvalidOperationException("Remote host closed the connection");
                     }
                     while (readBytes < length);
 
@@ -416,7 +422,7 @@ private async Task ReadTcp(CancellationToken cancellationToken)
                     OnNext(message);
                 }
             }
-            catch (Exception ex) when (ex is TaskCanceledException || ex is OperationCanceledException)
+            catch (Exception ex) when (ex is OperationCanceledException)
             {
             }
             catch (Exception ex)