fix: read ssl stream until no more bytes

Author: cnblogs-dudu

src/Enyim.Caching/Memcached/PooledSocket.cs

@@ -421,32 +421,41 @@ public async Task ReadAsync(byte[] buffer, int offset, int count)
             int read = 0;
             int shouldRead = count;
 
-            while (read < count)
+            try
             {
-                try
+                if (_useSslStream)
                 {
-                    int currentRead = (_useSslStream
-                        ? await _sslStream.ReadAsync(buffer, offset, shouldRead).ConfigureAwait(false)
-                        : await _inputStream.ReadAsync(buffer, offset, shouldRead).ConfigureAwait(false));
-                    if (currentRead == count)
-                        break;
-                    if (currentRead < 1)
-                        throw new IOException("The socket seems to be disconnected");
-
-                    read += currentRead;
-                    offset += currentRead;
-                    shouldRead -= currentRead;
+                    int currentRead = -1;
+                    do
+                    {
+                        currentRead = await _sslStream.ReadAsync(buffer, offset, shouldRead).ConfigureAwait(false);
+                    } while (currentRead != 0);
                 }
-                catch (Exception ex)
+                else
                 {
-                    if (ex is IOException || ex is SocketException)
+                    while (read < count)
                     {
-                        _isAlive = false;
+                        int currentRead = await _inputStream.ReadAsync(buffer, offset, shouldRead).ConfigureAwait(false);
+                        if (currentRead == count)
+                            break;
+                        if (currentRead < 1)
+                            throw new IOException("The socket seems to be disconnected");
+
+                        read += currentRead;
+                        offset += currentRead;
+                        shouldRead -= currentRead;
                     }
-
-                    throw;
                 }
             }
+            catch (Exception ex)
+            {
+                if (ex is IOException || ex is SocketException)
+                {
+                    _isAlive = false;
+                }
+
+                throw;
+            }
         }
 
         /// <summary>