Reactive.NET中的循环I可观察链

Question

我正在寻找实现循环IObservable链的最佳方法。

例如：

IObservable<B> Foo(IObservable<A> fizz)
{
    //stuff
}
IObservable<A> Bar(IObservable<A> fizz, IObservable<B> buzz)
{
    //stuff
}

我的实现：

var fizzes = new BehaviorSubject<A>();
var buzzes = Foo(fizzes);
Bar(fizzes, buzzes).Subscribe(f => fizzes.OnNext(f));

有更好的方法吗？使用Subject感觉很脏，而且通常不太优雅。

Answer 1

行

Bar(fizzes, buzzes).Subscribe(f => fizzes.OnNext(f));

可以变得更简单并更改为

Bar(fizzes, buzzes).Subscribe(fizzes);

由于Subscribe方法采用IObserver，因此通常使用的lambda方法只是这方面的快捷方式。

因此，fizzes被用作IObserver和IObservable，这是Subject的定义。如果这是您想要的行为，那么Subject可能就是您想要的方法。