我有一段代码,它使用RxJava来解析XML文件。每当读取新的XML标记时,-->onNext(event_data)就会被触发。
我想在"START_DOCUMENT"上分配一个类实体,并用XML解析的属性填充它。
我的问题是,我很难在RxJava流中做到这一点,因为它不是Observables链的一部分。我不知道如何分配实例,这样它就可以从Observables中访问,也不知道如何保留上下文。
这是我的代码:
链接到Gist和代码样本
谢谢!
查看scan
或reduce
。它们允许你在每次发射时携带一些状态,并在完成时发射该状态。CCD_ 3发出中间状态和完成状态,而CCD_。听起来你会用reduce
。