diff --git a/src/SuperSocket.Connection/PipeConnectionBase.cs b/src/SuperSocket.Connection/PipeConnectionBase.cs
index d390ddc15..cba380d7a 100644
--- a/src/SuperSocket.Connection/PipeConnectionBase.cs
+++ b/src/SuperSocket.Connection/PipeConnectionBase.cs
@@ -82,7 +82,12 @@ public async override IAsyncEnumerable<TPackageInfo> RunAsync<TPackageInfo>(IPip
             {
                 var package = await packagePipe.ReadAsync().ConfigureAwait(false);
 
-            e
+                if (package == null)
+                {
+                    yield break;
+                }
+
+                yield return package;
             }
 
             //How do empty a pipe?