2016-07-29 45 views
0

我有一個使用RxJava來解析XML文件的代碼。 每當讀取新的XML標記 - > onNext(event_data)時觸發。RxJava:創建在Observables鏈上運行的白色類實例

我想在「START_DOCUMENT」上分配一個類實體,並用XML解析的屬性填充它。

我的問題是,我在RxJava流程中努力工作,因爲它不是Observables鏈的一部分。我不知道如何分配實例,以便可以從Observables中訪問它,以及如何保持上下文。

這裏是我的代碼:

Link to Gist with code sample

謝謝!

回答

1

看看scanreduce。它們允許您在每次排放時完成一些狀態,並在完成時排出該狀態。 scan發出中間狀態和完成狀態,並且reduce剛剛發出完成狀態。聽起來像你會使用reduce