将一个可观察对象连接到另一个现有的可观察对象



我有两个可观察对象,一个产生元素,另一个是订阅者订阅的Subject。我希望订阅者得到的是通过第一个。一种方法是这样做:

 first.Subscribe(a => second.OnNext(a);

不知何故,我只喜欢在最后订阅,而不是订阅,只是管道一个到另一个。我很好奇,在我开始写我自己的Rx扩展之前,是否有任何Rx扩展允许这样的事情。

这个适合我:

var subject = new Subject<long>();
subject.Subscribe(x => Console.WriteLine(x));
var observable = Observable.Interval(TimeSpan.FromSeconds(1.0));
observable.Subscribe(subject);

我从Console.WriteLine观察者那里得到Interval观察者的一系列值。

相关内容

  • 没有找到相关文章