我有一个使用RxJava来解析XML文件的代码。
每当读取新的XML标记-> onNext(event_data)都会被触发。

我想在“ START_DOCUMENT”上分配一个类实体,并用XML解析的属性填充它。

我的问题是我在RxJava流中很难做到这一点,因为它不属于Observables链。我不知道如何分配实例,以便可以从Observables中访问它,以及如何保持上下文。

这是我的代码:

Link to Gist with code sample

谢谢!

最佳答案

看看scanreduce。它们允许您在每次发射时都带有某种状态,并在完成时发射该状态。 scan发出中间状态和完成状态,而reduce刚发出完成状态。听起来您会使用reduce

关于java - RxJava:创建在Observables链上运行的白色类实例,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/38662635/

10-10 11:50