Removed object pipe (#779)

Author: kerryjiang

src/SuperSocket.Client/EasyClient.cs

@@ -37,6 +37,8 @@ public abstract class EasyClient : IEasyClient
 
         internal static readonly int DefaultSocketSenderPoolSize = 10;
 
+        private bool _continuousReceivingStarted = false;
+
         protected EasyClient()
             : this(NullLogger.Instance)
         {
@@ -222,7 +224,9 @@ private void StartReceive()
                     client.OnError("The receive task was cancelled.");
                     return;
                 }
-            }, this, TaskContinuationOptions.OnlyOnFaulted);;
+            }, this, TaskContinuationOptions.OnlyOnFaulted);
+
+            _continuousReceivingStarted = true;
         }
 
         protected abstract Task StartReceiveAsync();
@@ -280,7 +284,17 @@ protected virtual async ValueTask SendAsync<TSendPackage>(IPackageEncoder<TSendP
 
         public virtual async ValueTask CloseAsync()
         {
-            await Connection.CloseAsync(CloseReason.LocalClosing);
+            var closeTask = Connection.CloseAsync(CloseReason.LocalClosing);
+
+            if (_continuousReceivingStarted)
+            {
+                await closeTask;
+            }
+            else
+            {
+                await Task.WhenAll(closeTask.AsTask(), StartReceiveAsync());
+            }
+            
             OnClosed(this, EventArgs.Empty);
         }
     }