Concat und zurück beobachtbare

Question

Ich versuche, herauszufinden, wie ein Ergebnis aus dem Netz zu bekommen, bleiben sie und stellen die reponse Körper auf die beobachtbare. So:

@Override 
    public Observable<DefaultUserResponse> createUser(CreateUserCommand command) { 
     return this.userService.createUser(command) 
       .map(defaultUserResponse -> { 
        User user = new User(); 
        defaultUserResponse.setUser(user); 
        return defaultUserResponse; 
       }).flatMap(defaultUserResponse -> persist(defaultUserResponse.getUser())); 
    } 

Observable<User> persist(User user) {return null;} 

Schritte:

1. bekomme ich einen DefaultUserResponse vom Server.
2. Den Befehl in einen Benutzer umwandeln (Befehl = DTO)
3. Den Benutzer lokal beibehalten.
4. Geben Sie die DefaultUserResponse zurück.

Wie soll ich vorgehen?

Dank

Answer 1

Betrachten Completable Typ für Ihre persist-Methode (wenn Sie über den Rückgabewert (e) do not care):

Completable persist(User user) { 
    return Completable.fromCallable(() -> { 
     //persisting 
     return null; 
    } 
} 

Dann könnten Sie andThen Operator zu warten, bis verwenden persistierenden abgeschlossen ist und Ihr Wert drücken weiter:

... 
.flatMap(defaultUserResponse -> persist(defaultUserResponse.getUser()).andThen(Observable.just(defaultUserResponse))); 

Oder wenn Sie noch Observable verwenden für persistierende Verwenden Sie einfach einen anderen flatMap anstelle von andThen.