如果我执行以下操作:
var obs =
Observable
.Interval(TimeSpan.FromSeconds(1))
.Select(x => "A" + x.ToString());
obs
.Subscribe(x => Console.WriteLine("From first: " + x.ToString()));
Observable
.Timer(TimeSpan.FromSeconds(3))
.SelectMany(_ => obs)
.Subscribe(x => Console.WriteLine("From second: " + x.ToString()));
4秒后我会得到这个:
From first: A0
From first: A1
From first: A2
From second: A0
From first: A3
有没有相当于“热”的词Observable.Interval
这会产生这样的结果:
From first: A0
From first: A1
From first: A2
From second: A3
From first: A3
使用 Publish() 和 Connect() 会将冷的可观察对象变成热的。
var published = Observable
.Interval(...)
.Select(...)
.Publish();
var connectionSubscription = published.Connect();
var observerSubscription = published.Subscribe(...);
值得注意的是,一旦 Connect() 调用发生,序列就会很热。您可以在 Connect() 之前订阅,但请确保在某个阶段调用它,否则将不会观察到任何内容。 Connect() 有一些替代方案,例如RefCount() 值得谷歌一下。另外值得注意的是,Publish() 返回一个提供 Connect() 调用的 IConnectableObservable。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)