Wie vervollständige ich die Completable FlatMap-Kette?

Question

Ich habe eine Aufgabe, um eine Verbindung zum Remote-Service herzustellen. Wenn es nicht angeschlossen ist - starten Sie den gesamten Verbindungsvorgang, falls bereits verbunden - einfach abschließen. Zu diesem Zweck habe ich diese Methode -

Im ersten Fall, wenn der Service nicht verbunden ist - alles funktioniert gut. Aber wenn in der ersten Stufe isConnected() TRUE zurückgibt, werden alle Chain-Stalle und Completable überhaupt nicht abgeschlossen. Was kann ich tun, um die erste Stufe zu erzwingen?

Answer 1

 

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

Was Sie damit gesagt haben, ist, dass, wenn isConnectedtrue ist, dann nie ein Element emittiert, wodurch diese beobachtbar wird nie enden.

Stattdessen sollten Sie Downstream einem Single of false passieren:

 

    .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