подписывается на наблюдаемый, когда другой наблюдаемый завершает

Question

Сохранение его простого и короткого, как подписаться на наблюдаемый в методе onNext() другого абонента, чтобы мы могли делать только вложенную подписку, когда текущий наблюдаемый завершает свое выполнение. Обе подписки будут сделаны в отдельных потоках, и требование состоит в том, чтобы первый поток завершил выполнение до начала второго потока.

makeObservable() 
.subscribeOn(Schedulers.newThread()) 
.subscribe(new Subscriber<User> { 
    @override 
    void onNext(User user){ 
    //do something 
    //make another subscription here 
}); 

Answer 1

Не делайте новую подписку, вернуть другой Observable и подписаться на него.

apiCall() 
.subscribeOn(<scheduler>) 
.observeOn(<scheduler>) 
.flatMap(new Func1<User, Observable<Something>() { 
    @Override 
    public Observable<Something> call(User user) { 
     return Observable.just(<example>); 
    } 
}); 

редактировать: при возврате апи вызова, flatMap будет перехватывать поток, и оттуда, либо вернуть Observable или вызвать функцию, которая возвращает Observable (то есть другой апи вызов).

Answer 2

Если они оба излучают одни и те же предметы, используйте Observable.concat(), который подписывается на наблюдаемый N + 1 после наблюдения наблюдаемого N. Но, возможно, стоит описать ваш вариант использования более подробно.

Edit: Вы должны быть в состоянии сделать что-то вроде:

userClient 
.saveUser(user) 
.flatMap(userSaveResult -> 
    userClient 
    .saveUserDetails(userSaveResult.id, seuser.getDetails)) 
.onError(...)