esiur/esiur-dotnet
2
0
Fork 0
mirror of https://github.com/esiur/esiur-dotnet.git synced 2026-03-31 18:38:22 +00:00
Code Issues Projects Releases Wiki Activity

Merge branch 'ver-3' of https://github.com/esiur/esiur-dotnet into ver-3

Browse Source
This commit is contained in:
ahmed
2026-03-17 19:10:35 +03:00
parent 8fc07d6350 cb3d565263
commit 9d936c0812
4 changed files with 33 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
Esiur/Net/IIP/DistributedConnectionProtocol.cs
View File

@@ -1362,7 +1362,36 @@ partial class DistributedConnection
return;
}
if (rt is System.Collections.IEnumerable && !(rt is Array || rt is Map<string, object> || rt is string))
if (rt is IAsyncEnumerable<object>)
{
var enu = rt as IAsyncEnumerable<object>;
var enumerator = enu.GetAsyncEnumerator();
Task.Run(async () =>
{
try
{
while (await enumerator.MoveNextAsync())
{
var v = enumerator.Current;
SendChunk(callback, v);
}
SendReply(IIPPacketReply.Completed, callback);
if (context != null)
context.Ended = true;
}
catch (Exception ex)
{
if (context != null)
context.Ended = true;
var (code, msg) = SummerizeException(ex);
SendError(ErrorType.Exception, callback, code, msg);
}
});
}
else if (rt is System.Collections.IEnumerable && !(rt is Array || rt is Map<string, object> || rt is string))
{
var enu = rt as System.Collections.IEnumerable;