以事件後，才從鏈可觀察到的已發出一個

Question

這裏是鏈：observableOne.flatMap(event -> observableTwo).subscribe()

我想借此事件從observableOne的第一次它發出一個，則忽略此Observable所有其他事件直到observableTwo已發出一個值，完成或完成一個錯誤。值得一提的是，我最終對第二個Observable的事件感興趣。

上下文相似，有一個Button點擊哪個事件被觸發，這是ObservableOne。被觸發的事件觸發ObservableTwo，假設它是一系列網絡操作。所以我想在執行網絡操作時忽略所有按鈕點擊。

Answer 1

來控制flatMap提出的請求量使用特殊的過載：

observableOne 
    .doOnRequest(System.out::println) 
    .flatMap(event -> observableTwo, 1) 
    .flatMap(event -> observableThree, 1) 
.subscribe() 

如果你的源代碼observableOne，observableTwo，observableThree是同步的這不應該是必要的，但對於異步資源本應做的工作。

Answer 2

[EDIT2]改變，所以我適應我的答案+實際上給一個正確的答案

我看不出這樣做比用狀態標誌的其他方式的問題：

AtomicBoolean progress = new AtomicBoolean(); 
observableOne 
     .filter(event -> !progress.get()) 
     .flatMap(event -> 
       observableTwo 
         .doOnSubscribe(() -> progress.set(true)) 
         .doOnTerminate(() -> progress.set(false)) 
     ) 
     .subscribe(); 

如果發生錯誤時，您的訂閱將被取消，即使再次單擊該按鈕，也不會再收到任何事件。

如果這不是你想要的，你可以：在錯誤回調

private void bindRemoteCalls() { 
    if (mySubscription != null) mySubscription.unsubscribe(); 
    AtomicBoolean progress = new AtomicBoolean(); 
    mySubscription = observableOne 
     .filter(event -> !progress.get()) 
     .flatMap(event -> 
       observableTwo 
         .doOnSubscribe(() -> progress.set(true)) 
         .doOnTerminate(() -> progress.set(false)) 
     ) 
     .flatMap(event -> observableTwo, 1) 
     .subscribe(
      data -> handleResponse(data), 
      error -> { 
       handleError(error); 
       bindRemoteCalls(); 
      } 
     ); 
} 

使用onErrorReturn()（用doOnError()結合實際做一些事情）

• 重新訂閱

  AtomicBoolean progress = new AtomicBoolean(); 
  observableOne 
      .filter(event -> !progress.get()) 
      .flatMap(event -> 
        observableTwo 
          .doOnSubscribe(() -> progress.set(true)) 
          .doOnTerminate(() -> progress.set(false)) 
          .doOnError(error -> handleError(error)) 
          .onErrorReturn(null) 
          .filter(data -> data != null) 
      ) 
      .subscribe(data -> handleResponse(data)); 
  

如果您需要，請記得使用subscribeOn()/observeOn()以及正確的調度程序。

請考慮用switchMap()代替flatMap() - >如果再次按下該按鈕，先前的呼叫被取消（取消訂閱），然後開始新的呼叫。或者用Rx來表示：observableTwo先前的訂閱已取消訂閱，並且形成了新的訂閱。

如果您在取消訂閱時禁用了您的按鈕並在終止時啓用了它，您可以通過使按鈕不可點擊來輕鬆獲得相同的結果。