如何在没有阻止呼叫的情况下从Iobservable订阅中获取结果？

发布于 2025-01-20 17:59:36 字数 1072 浏览 4 评论 0原文

我正在尝试使用 ListObjectsAsync 方法。

以下是相关代码：

public async Task<string> GetFileName(string userID, string datasetID) 
{
    ListObjectsArgs args = new ListObjectsArgs()
        .WithBucket(userID)
        .WithPrefix(datasetID)
        .WithRecursive(true);

    var files = _minio.ListObjectsAsync(args);

    List<string> fileNames = new();
    
    IDisposable subscription = files
        .Subscribe(item => 
            fileNames.Add(item.Key),
            () => Console.WriteLine(fileNames.Count)
        );
      
    // I want to return one of the filenames here!
    return ""; 
}

上面的代码按预期填充列表 fileNames 并打印出相应位置中正确的文件数量。但是，我想在上面的函数中使用数据。我知道我可以执行以下操作：

files.ToList().Wait();

但是，这是一个阻塞调用。我应该简单地将这个调用包装到 Task 中还是有其他（更好）的方法来获取所需的数据？

原文

I'm trying to get filenames within a bucket of my MinIO server using the ListObjectsAsync method.

Here is the relevant code:

public async Task<string> GetFileName(string userID, string datasetID) 
{
    ListObjectsArgs args = new ListObjectsArgs()
        .WithBucket(userID)
        .WithPrefix(datasetID)
        .WithRecursive(true);

    var files = _minio.ListObjectsAsync(args);

    List<string> fileNames = new();
    
    IDisposable subscription = files
        .Subscribe(item => 
            fileNames.Add(item.Key),
            () => Console.WriteLine(fileNames.Count)
        );
      
    // I want to return one of the filenames here!
    return ""; 
}

The code above fills the list fileNames as expected and prints out the correct number of files within the respective locations. However, I would like to user the data within the function above.
I know I could do the following:

files.ToList().Wait();

However, this is a blocking call. Should I simply wrap this call into Task or is there some other (better) way to get the required data?

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

空城缀染半城烟沙 2025-01-27 17:59:36

而不是订阅，而是返回files.totask（）。

如您在评论中提到的编辑

，首先使用.tolist（），以将所有下一个事件收集到一个事件中。如果您正在寻找一个特定文件，就像另一个答案所暗示的那样，请使用.filter。

另外，我认为您的返回类型应该是带有一系列字符串而不是单个字符串的任务...（除非您只想要一个文件并过滤了所有其他文件。）

回复收藏 0 原文

荆棘i 2025-01-27 17:59:36

我认为您可以将收到的文件一一检查，并在当前文件满足特定条件时停止处理其余文件。喜欢：

CancellationTokenSource source = new CancellationTokenSource();
CancellationToken token = source.Token;
Item file = null;
files.Subscribe(
        item => {
            if (item.Key=="MyFile")
            {
                file=item; 
                source.Cancel();
            }
        },
        () => Console.WriteLine(fileNames.Count),
        token );

I think you can check the files you received one by one and stop processing the rest of them when the current file meets a specific condition. Like:

CancellationTokenSource source = new CancellationTokenSource();
CancellationToken token = source.Token;
Item file = null;
files.Subscribe(
        item => {
            if (item.Key=="MyFile")
            {
                file=item; 
                source.Cancel();
            }
        },
        () => Console.WriteLine(fileNames.Count),
        token );

回复收藏 0 原文

~没有更多了~