どのように正しく完成するflatMapチェーン内のCompletable？

Question

リモートサービスに接続するタスクがあります。それが接続されていないとき - 接続手順全体を起動します。この目的のために、私はこのメソッドを書いた -

public Completable execute() { 
     return fptrService.isConnected() 
      .flatMap(isConnected -> { 
       if (isConnected) return Single.never(); 
       else return bluetoothService.isBluetoothAvailable(); 
      }) 
      .flatMap(isAvailable -> { 
       if (isAvailable) return bluetoothService.isBluetoothActivated(); 
       else throw new BluetoothNotAvailableException(); 
      }) 
      .flatMap(isActivated -> { 
       if (isActivated) return bluetoothService.searchForFptr(); 
       else throw new BluetoothNotActivatedException(); 
      }) 
      .flatMapCompletable(fptrService::connect); 
    } 

第1の場合、サービスが接続されていない - すべて正常に動作します。しかし、最初の段階でisConnected（）がTRUEを返し、すべてのチェーン・ストールとCompletableはまったく完了しません。私は最初の段階で完全に強制することができますか？あなたはこれで言った何

Answer 1

 

    .flatMap(isConnected -> { 
     if (isConnected) return Single.never(); 
     else return bluetoothService.isBluetoothAvailable(); 
    }) 
 

、isConnectedがtrueであれば、その後、このように、この観測可能な意志が終了したことがない、アイテムを放出しないことです。

代わりに、あなたは下流Single of false渡す必要があります。

 

    .flatMap(isConnected -> { 
     if (isConnected) return Single.just(Boolean.FALSE); 
     else return bluetoothService.isBluetoothAvailable(); 
    }) 
    // Will continue stream if `isConnected` is true 
    .filter(isConnected -> isConnected) 
    // if `isConnected` is false, then downstream operators won't be executed