riley/Beam
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor: update DownloadEnumerable to use IAsyncEnumerable

Browse Source 
The DownloadEnumerable class has been refactored to accept
an IAsyncEnumerable<Ordered<T>> instead of an IAsyncEnumerator<Ordered<T>>.
This change simplifies the class and improves its usability.

This allows for better integration with asynchronous streaming
of data, enhancing performance and flexibility.
This commit is contained in:
qwsdcvghyu89
2025-06-26 14:52:00 +03:00
parent 3569ee0e87
commit 87360d75ab
1 changed files with 12 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Beam/DownloadEnumerable.cs
+12 -6
View File
@@ -5,13 +5,19 @@ using System.Text;
using System.Threading.Tasks;
namespace Beam {
public class DownloadEnumerable<T>(IAsyncEnumerator<Ordered<T>> download) : IAsyncEnumerable<Ordered<T>> {
public IAsyncEnumerator<Ordered<T>> Download { get; } = download;
//public class DownloadEnumerable<T>(IAsyncEnumerator<Ordered<T>> download) : IAsyncEnumerable<Ordered<T>> {
// public IAsyncEnumerator<Ordered<T>> Download { get; } = download;
public IAsyncEnumerator<Ordered<T>> GetAsyncEnumerator(CancellationToken cancellationToken = default)
=> Download;
// public IAsyncEnumerator<Ordered<T>> GetAsyncEnumerator(CancellationToken cancellationToken = default)
// => Download;
public static DownloadEnumerable<T> Empty()
=> new(Array.Empty<Ordered<T>>().ToAsyncEnumerable().GetAsyncEnumerator());
// public static DownloadEnumerable<T> Empty()
// => new(Array.Empty<Ordered<T>>().ToAsyncEnumerable().GetAsyncEnumerator());
//}
public class DownloadEnumerable<T>(IAsyncEnumerable<Ordered<T>> download) : IAsyncEnumerable<Ordered<T>> {
public IAsyncEnumerator<Ordered<T>> GetAsyncEnumerator(CancellationToken cancellationToken = default) {
return download.GetAsyncEnumerator(cancellationToken);
}
}
}