Rx.Net：链接订阅者 - 替代方法？

Question

如何重写这段代码，这样我就不必像下面这样链接订阅者了？询问的原因是，由于代码的风格，这种风格将限制在一个可观察的对象中，这取决于另一个可观察的对象，这可能会让人感到困惑。

var results = myService
          .GetData(accountId)    // returns IObservable
          .Subscribe(data =>
          {
              new MyWork().Execute(data)  // returns IObservable
                  .Subscribe(result =>
                  {
                      myResults.Add(result);
                      WriteLine($"Result Id: {result.Id}");
                      WriteLine($"Result Status: {result.Pass}");
                  });
          });

在来自 Peter Bons

的第一个回复 后添加

下面是 MyWork class 的代码，它具有执行方法

public class MyWork 
{
    public virtual IObservable<MyResult> Execute(MyData data)
    {
        MyResult result = null;

        return IsMatch(data)
            .Do(isMatch =>
            {
                if (isMatch)
                {
                    result = new MyResult(1, true);
                }
            })
            .Select(_ => result);
    }


    public IObservable<bool> IsMatch(MyData data)
    {
        return true;
    }
}

Answer 1

真的很简单。

var results =
    myService
      .GetData(accountId)
      .SelectMany(data => new MyWork().Execute(data))
      .Subscribe(result =>
      {
          myResults.Add(result);
          Console.WriteLine($"Result Id: {result.Id}");
          Console.WriteLine($"Result Status: {result.Pass}");
      });

如果您在订阅中进行订阅，那么您就做错了。记住这一点。几乎总有一种方法可以使其成为具有单个订阅的纯查询。

只是为了帮助测试，这里是使它成为 Minimal, Complete, and Verifiable example 所需的代码。

public static class myService
{
    public static IObservable<MyData> GetData(int x)
        => Observable.Return(new MyData());
}

public class MyWork 
{
    public virtual IObservable<MyResult> Execute(MyData data)
    {
        MyResult result = null;

        return IsMatch(data)
            .Do(isMatch =>
            {
                if (isMatch)
                {
                    result = new MyResult() { Id = 1, Pass = true};
                }
            })
            .Select(_ => result);
    }


    public IObservable<bool> IsMatch(MyData data)
    {
        return Observable.Return(true);
    }
}

public class MyResult
{
    public int Id;
    public bool Pass;
}

public class MyData { }

Rx.Net：链接订阅者 - 替代方法？

Rx.Net: Chaining subscribers - alternative approach?

system.reactive

rx.net