Added usings to ReadTcp CancellationTokenSources

Author: Ahmad Noman Musleh

src/OpenAPI.Net/Auth/TokenFactory.cs

@@ -81,6 +81,13 @@ public static async Task<Token> GetToken(string authCode, App app, HttpClient cl
             throw new HttpRequestException($"{response.StatusCode}, The HTTP request for getting access token was not successful");
         }
 
+        /// <summary>
+        /// Returns the URI for getting access token
+        /// </summary>
+        /// <param name="authCode">The authentication code</param>
+        /// <param name="app">API application</param>
+        /// <param name="authUri">The auth URI base path</param>
+        /// <returns>Uri</returns>
         public static Uri GetUri(string authCode, App app, string authUri = ApiInfo.AuthUrl)
         {
             var query = new NameValueCollection
@@ -95,6 +102,12 @@ public static Uri GetUri(string authCode, App app, string authUri = ApiInfo.Auth
             return new Uri($"{authUri}token{query}");
         }
 
+        /// <summary>
+        /// Deserializes a JSON token response to Token object
+        /// </summary>
+        /// <param name="json">JSON response</param>
+        /// <returns>Token</returns>
+        /// <exception cref="JsonException"></exception>
         public static Token DeserializeToken(string json)
         {
             var token = JsonSerializer.Deserialize<Token>(json);

src/OpenAPI.Net/OpenClient.cs

@@ -331,7 +331,7 @@ private async Task ConnectTcp()
 
             await _sslStream.AuthenticateAsClientAsync(Host).ConfigureAwait(false);
 
-            _ = ReadTcp(_cancellationTokenSource.Token);
+            _ = ReadTcp();
         }
 
         /// <summary>
@@ -373,7 +373,7 @@ private async Task StartSendingMessages(CancellationToken cancellationToken)
         /// This method will read the TCP stream for incoming messages
         /// </summary>
         /// <returns>Task</returns>
-        private async Task ReadTcp(CancellationToken cancellationToken)
+        private async Task ReadTcp()
         {
             try
             {
@@ -387,7 +387,7 @@ private async Task ReadTcp(CancellationToken cancellationToken)
                     {
                         var count = lengthArray.Length - readBytes;
 
-                        var cancellationTokenSource = new CancellationTokenSource(TimeSpan.FromSeconds(20));
+                        using var cancellationTokenSource = new CancellationTokenSource(TimeSpan.FromSeconds(20));
 
                         readBytes += await _sslStream.ReadAsync(lengthArray, readBytes, count, cancellationTokenSource.Token).ConfigureAwait(false);
                     }
@@ -407,7 +407,7 @@ private async Task ReadTcp(CancellationToken cancellationToken)
                     {
                         var count = data.Length - readBytes;
 
-                        var cancellationTokenSource = new CancellationTokenSource(TimeSpan.FromSeconds(20));
+                        using var cancellationTokenSource = new CancellationTokenSource(TimeSpan.FromSeconds(20));
 
                         readBytes += await _sslStream.ReadAsync(data, readBytes, count, cancellationTokenSource.Token).ConfigureAwait(false);
                     }