fix bus

kerryjiang · May 11, 2024 · 6b11ba8 · 6b11ba8
1 parent 26fd35c
commit 6b11ba8
Showing 1 changed file with 6 additions and 1 deletion.
diff --git 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?