合并多个可观察量并更新现有订阅者？
合并多个可观察量并更新现有订阅者？
提问于 2019-06-05 01:10:50
如何将可能会或可能没有订阅者的热点可观察量聚合到一个新的可观察量中，并继续向现有订阅者提供所有新数据？
举个例子，假设我们有一些这样的类：
class SomeClass
{
IObservable<string> Actions { get; set; } = Observable.Empty<string>();
void AddActionCreator(IObservable<string> creator)
{
Actions = Actions.Merge(creator);
}
}
我AddActionCreator遇到的问题是，如果添加新的操作流，那么SomeClass.Actions在合并新流之前订阅的任何先前订阅者将永远不会获得新操作。
Stack Overflow用户
发布于 2019-06-05 10:38:45
做你想做的事很容易。你需要的是a SelectMany和a Subject<IObservabe<string>>。
这是你需要的课程：
public class SomeClass
{
private Subject<IObservable<string>> _sources = new Subject<System.IObservable<string>>();
public IObservable<string> Actions { get; private set; } = null;
public SomeClass()
{
this.Actions = _sources.SelectMany(x => x);
}
public void AddActionCreator(IObservable<string> creator)
{
_sources.OnNext(creator);
}
}
现在您可以像这样使用它：
var sc = new SomeClass();
sc.Actions.Subscribe(x => Console.WriteLine($"1:{x}"));
sc.AddActionCreator(Observable.Return("Hello"));
sc.Actions.Subscribe(x => Console.WriteLine($"2:{x}"));
sc.AddActionCreator(Observable.Range(0, 3).Select(x => $"{x}"));
sc.Actions.Subscribe(x => Console.WriteLine($"3:{x}"));
sc.AddActionCreator(Observable.Return("World"));
你会得到这个输出：
1：你好
1:0
1:1
1:2
2:0
2:1
2:2
1：世界
2：世界
3：世界
您可以看到新的observable已添加到现有订阅者。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/-100006922
复制相关文章
相似问题