RxJava的Android toMap操作員停止執行

Question

你好，我試圖使用RX Java進行下一個任務

1. 形式的顯示領域
2. 上mistaked領域顯示錯誤
3. 返回可觀察>有效字段的 - >值

解決方案

List<Observable<RxUtil.EditTextEvent>> listOfObs = new ArrayList<>(); 

...fill form, fill listOfObs 

return Observable.merge(listOfObs) // stream of EdtText events 
      .debounce(5, TimeUnit.MILLISECONDS) 
      .observeOn(AndroidSchedulers.mainThread()) 
      .doOnNext((onTextChangeEvent) -> { // show error, if user made mistake 
       if (!CheckOutUtils.isInputCorrect(onTextChangeEvent)) 
        onTextChangeEvent.editText.setError("Проверьте поле"); 
      }) 
      .filter(CheckOutUtils::isInputCorrect) // only valid fields 
      .toMap(editTextEvent -> (Field) editTextEvent.editText.getTag(), editTextEvent -> editTextEvent.text) // called on every change 
      .doOnNext(fieldStringMap -> { 
       Log.v("map", fieldStringMap.toString()); // never called 
      }); // map of it 

最後一個操作符永遠不會被調用。 toMap是最後一個執行操作符。怎麼了？

Answer 1

我聽的文字改變事件，並做了打掃在以某種方式中的所有文本字段：

List<TextField> fields = ... 

Observable<TextField> all = Observable.from(fields); 

all 
.flatMap(f -> RxUtil.textChangedObservable(f)) 
.debounce(5, TimeUnit.MILLISECONDS) 
.observeOn(AndroidSchedulers.mainThread()) 
.flatMap(f -> 
    all 
    .filter(f -> isCorrect(f.getText())) 
    .toMap(f -> f.getTag(), f -> getText()) 
) 
.subscribe(System.out::println); 

我不熟悉RxUtil但你可能會發現必要的方法。

Answer 2

問題很可能是您的源observable不完全。 toMap()運營商將不會調用onNext()，直到源observable完成。以下是toMap()的大理石圖表供參考。