RxJava 코드의 조건부 연산

Question

저는 RxJava를 처음 사용하고 있으며 종종 아래 조건부 연산과 같은 솔루션을 사용하고 있습니다. 여기에 두 개의 호출을 차례로 연결 한 다음 호출 체인의 결과가 무엇인지에 따라 int를 반환하려고합니다. 이 코드를 향상시키는 "rxified"방법이 있습니까? @ andrei-에 의해 제안으로 받아 들여 확인하기 위해 논리를 이동 한 후

return restApiAdapter.closePosition(request) 
      .flatMap(dealReference -> restApiAdapter.getDealConfirmationObservable(dealReference.getValue()) 
       .map(dealConfirmationResponse -> { 
        if (dealConfirmationResponse.getDealStatus() == DealStatus.ACCEPTED) { 
         return SUCCESS.getValue(); 
        } else { 
         return FAIL.getValue(); 
        } 
       }) 
      ) 
      .onErrorReturn(e -> ZorroReturnValues.BROKER_SELL_FAIL.getValue()) 
      .blockingSingle(); 

Answer 1

/거부 됨 주문 (필자는 아직 현재의 값을 밀어 수있는 기존의 응용 프로그램에하는 int 결과를 전달하고있어 이후 여기 blockingSingle 사용) macarie, 코드는 이제 다음과 같이 보입니다.

return restApiAdapter.closePosition(request) 
      .flatMap(dealReference -> restApiAdapter.getDealConfirmationObservable(dealReference.getValue()) 
       .map(dealConfirmationResponse -> SUCCESS.getValue() 
      ) 
      .onErrorReturn(e -> FAIL.getValue()) 
      .blockingSingle();