首页 / C# / c# – 嵌套的Observable在Wait()上挂起

c# – 嵌套的Observable在Wait()上挂起

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了c# – 嵌套的Observable在Wait()上挂起，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1913字，纯文字阅读大概需要3分钟。

内容图文

在C#控制台应用程序中,使用System.Reactive.Linq,我正在尝试创建一个observable,其中每个项目是由另一个observable进行某些处理的字符串结果.
我用字符串和字符创建了一个简单的repro.
警告,此示例完全是CONTRIVED,重点是嵌套的.Wait()挂起.

class Program
{
    static void Main(string[] args)
    {
        string[] fileNames = { "file1.doxc", "file2.xlsx", "file3.pptx" };
        IObservable<string> files = fileNames.ToObservable();
        string[] extensions = files.Select(fn =>
        {
            var extension = fn.ToObservable()
            .TakeLast(4)
            .ToArray()
            .Wait(); // <<<<<<<<<<<<< HANG HERE
            return new string(extension);
        })
        .ToArray()
        .Wait();
    }
}

同样,这不是我如何找到许多文件名的后缀.
问题是我如何生成一个Observable of strings,其中字符串是从一个完整的observable计算出来的.

如果我拿出这个代码并单独运行它就可以了.

     var extension = fn.ToObservable()
        .TakeLast(4)
        .ToArray()
        .Wait();

有一些关于异步方法的嵌套Wait(),我不明白.

我如何编写嵌套的异步observable,所以我可以生成一个简单的字符串数组？

谢谢

-约翰

解决方法:

您的代码阻塞的原因是您在不指定调度程序的情况下使用ToObservable().在这种情况下,它将使用CurrentThreadScheduler.

因此,文件observable使用当前线程发出它的第一个OnNext()[A](发送“file1.doxc”).在OnNext()返回之前,它无法继续迭代.但是,内部fn observable也使用ToObservable()和Wait()块直到fn完成 – 它会将第一个OnNext()(发送“f”)排队到当前线程调度程序,但它永远无法发送它,因为现在第一个OnNext()[A]将永远不会返回.

两个简单的修复：

要么像这样改变文件可观察性：

IObservable<string> files = fileNames.ToObservable(NewThreadScheduler.Default);

或者,避免使用带有SelectMany的内部Wait()(这肯定是更惯用的Rx)：

string[] extensions = files.SelectMany(fn =>
{
    return fn.ToObservable()
             .TakeLast(4)
             .ToArray()
             .Select(x => new string(x));
})
.ToArray()
.Wait();

// display results etc.

每种方法都有完全不同的执行语义 – 第一种方法将像嵌套循环一样运行,每个内部observable在下一次外部迭代之前完成.第二个将更加交错,因为删除了Wait()的阻塞行为.如果你使用我编写的Spy方法并在ToObservable()调用之后附加它,你会很清楚地看到这种行为.

内容总结

以上是互联网集市为您收集整理的c# – 嵌套的Observable在Wait()上挂起全部内容，希望文章能够帮你解决c# – 嵌套的Observable在Wait()上挂起所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/805496.html

来源：【匿名】