RxJava:创建在Observables链上运行的类实例white



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

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

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

这是我的代码:

链接到Gist和代码样本

谢谢!

查看scanreduce。它们允许你在每次发射时携带一些状态,并在完成时发射该状态。CCD_ 3发出中间状态和完成状态,而CCD_。听起来你会用reduce

最新更新