don't throw exception

Author: kerryjiang

src/SuperSocket.Connection/PipeConnectionBase.cs

@@ -117,43 +117,16 @@ public async override IAsyncEnumerable<TPackageInfo> RunAsync<TPackageInfo>(IPip
 
             _connectionTask = GetConnectionTask(readTaskCompletionSource.Task, _cts.Token);
 
-            var packagePipeEnumerator = ReadPipeAsync<TPackageInfo>(InputReader, _cts.Token).GetAsyncEnumerator(_cts.Token);
-
-            Exception exception = null;
-
-            while (true)
+            try
             {
-                var read = false;
-
-                try
-                {
-                    read = await packagePipeEnumerator.MoveNextAsync().ConfigureAwait(false);
-                }
-                catch (OperationCanceledException)
-                {
-                    break;
-                }
-                catch (Exception e)
-                {
-                    exception = e;
-                    OnError("Unhandled exception in the method PipeConnection.Run.", e);
-                    break;
-                }
-
-                if (read)
+                await foreach (var packageInfo in ReadPipeAsync<TPackageInfo>(InputReader, _cts.Token))
                 {
-                    yield return packagePipeEnumerator.Current;
-                    continue;
+                    yield return packageInfo;
                 }
-
-                break;
             }
-
-            readTaskCompletionSource.TrySetResult();
-
-            if (exception != null)
+            finally
             {
-                throw exception;
+                readTaskCompletionSource.TrySetResult();
             }
 
             yield break;
@@ -391,8 +364,6 @@ protected async IAsyncEnumerable<TPackageInfo> ReadPipeAsync<TPackageInfo>(PipeR
         {
             var pipelineFilter = _pipelineFilter as IPipelineFilter<TPackageInfo>;
 
-            Exception exception = null;
-
             while (!cancellationToken.IsCancellationRequested)
             {
                 ReadResult result;
@@ -431,7 +402,6 @@ protected async IAsyncEnumerable<TPackageInfo> ReadPipeAsync<TPackageInfo>(PipeR
 
                         if (bufferFilterResult.Exception != null)
                         {
-                            exception = bufferFilterResult.Exception;
                             OnError("Protocol error", bufferFilterResult.Exception);
                             CloseReason = Connection.CloseReason.ProtocolError;
                             Close();
@@ -460,12 +430,6 @@ protected async IAsyncEnumerable<TPackageInfo> ReadPipeAsync<TPackageInfo>(PipeR
             }
 
             await CompleteReaderAsync(reader, _isDetaching).ConfigureAwait(false);
-
-            if (exception != null)
-            {
-                throw exception;
-            }
-
             yield break;
         }