Holen Sie sich das vorletzte beobachtbaren einer verketteten Karte() -Aufruf in Rx Java

Question

Ich habe zwei Observablen:

1. Observable<User> createUser(UserData userData)
2. Observable<Void> loginUser(User user)

Nachdem der Benutzer erstellt ein neues Konto Ich möchte anmelden mit diesem neuen Konto. Also habe ich das getan:

createUser(userData).map(user -> loginUser(user)); 

Aber auf diese Weise erhalte ich eine Observable<Void> als Rückkehr. Ich möchte createUser(userData).map(user -> loginUser(user)) anrufen und eine Observable<User> als Rückgabe erhalten. Etwas wie dieses:

@Override 
public Observable<User> createUserAndLogin(){ 

    createUser(userData).map(user -> loginUser(user)); 

} 

Wie könnte ich das tun?

Answer 1

Warum nicht Log-in als Nebeneffekt mit doOnNext verwenden?

createUser(userData).doOnNext(user -> loginUser(user)); 

Wenn Sie sicher, dass die Log-in machen wollen passiert:

createUser(userData).flatMap(user -> { 
    // attach a callback to the log-in and return 
    // the user from the previous call 
    return loginUser(user).map(dontCare -> user); 
}); 

Aber ich bin nicht sicher, wie es geht, zu arbeiten, wenn loginUser nichts abgibt, so vielleicht gewaltsam concat den gewünschten Wert zum leeren loginUser beobachtbar:

createUser(userData).flatMap(user -> { 
    // attach a callback to the log-in and return 
    // the user from the previous call 
    return loginUser(user).concatWith(Observable.just(user)); 
});