异步发布到 Observable/Subject

Question

虽然我认为我已经掌握了如何使用 RxJava 的基础知识，但我在使用观察者模式时遇到了麻烦。

基本上，我想要做的是有一个静态的List 对象，我可以监控，并使用添加到列表中来将此数据提交给网络服务。

到目前为止，我的方法只是创建一个static List<Object> 和一个static Observable<Object>。这个 observable 是通过做一个

observable = Observable.from(listOfObjects);

然后，我的上传逻辑包含在 .subscribe() 调用中。如果我提前设置了List，这将起作用，但我想在运行时到处填充它。如果我再次致电.subscribe()，这仍然有效，但感觉就像我这样做是做错了什么。我以为我可以让现有订阅只对从可观察对象发出的任何新项目采取行动，但是当我添加到列表时似乎没有发生任何事情。

感谢任何关于更好/正确方法的见解。

Answer 1

Observable.from(listOfObjects) 将创建一个新的 observable，它将发出列表的每个对象。你也可以写Observable.just(1, 2, 3, 4)。这是同一件事。

因此，如果您将对象添加到列表中，Observable 将不会收到通知。

您可以创建一个自定义列表，该列表将通知您的Observable 新添加的项目。你会看到一个非常接近他的主题的解决方案：How can I create an Observer over a dynamic list in RxJava?

但是，您可以跳过您的列表，也可以使用Subject 来代替？无需将对象添加到您的列表中，只需调用 theSubject.onNext 方法即可。

请注意，只有在添加项目时才会通知您。删除项目时不会通知您。如果您愿意，您的 Observable 不应发出添加的项目，而是发出具有关联状态的项目：例如 new Added<Object>(item)、new Removed<Object>(item)。