我有一个使用RxJava来解析XML文件的代码。
每当读取新的XML标记-> onNext(event_data)都会被触发。
我想在“ START_DOCUMENT”上分配一个类实体,并用XML解析的属性填充它。
我的问题是我在RxJava流中很难做到这一点,因为它不属于Observables链。我不知道如何分配实例,以便可以从Observables中访问它,以及如何保持上下文。
这是我的代码:
Link to Gist with code sample
谢谢!
最佳答案
看看scan
或reduce
。它们允许您在每次发射时都带有某种状态,并在完成时发射该状态。 scan
发出中间状态和完成状态,而reduce
刚发出完成状态。听起来您会使用reduce
。
关于java - RxJava:创建在Observables链上运行的白色类实例,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/38662635/