Как вы связываете несколько наблюдаемых?

Question

Предположим, я хочу показать некоторые пользовательские данные, которые находятся на сервере. Я бы поискал сервер, кешировал его, а затем представлял его пользователю. Так что мой intial код RxJava будет выглядеть примерно так:

ApiClient.getUser(userId), //An Observable that will spit out a UserResponse 
    .subscribeOn(Schedulers.io()) //for the API observable (Do i need this?) 
    .flatMap(new Func1<UserResponse, Observable<DatabasePutResult>>() { 
      @Override 
      public Observable<DatabasePutResult> call(UserResponse response) { 
       return Database.cacheUser(response); 
      } 
      }) 
    .subscribeOn(Schedulers.io()) //for the database observable 
    .observeOn(AndroidSchedulers.mainThread()) 
    .subscribe(//handle DatabasePutResult object in onNext()); 

Теперь у меня есть два вопроса.

1. Это правильный способ соединения двух наблюдаемых? Если нет, как я должен это делать?
2. Если бы я хотел обработать onError для Наблюдаемого Апи, мог бы я как-то его поддерживать, сохраняя цепочку? Если нет, то каков наилучший способ сделать это? Действительно ли мне нужно разделить цепочку на два набора вызовов RxJava?

Answer 1

1. Вам не нужно это:

.subscribeOn(Schedulers.io()) //for the API observable (Do i need this?)

Если вас интересует, вы можете проверить идентификатор текущего потока с помощью этого кода:

Thread.currentThread().getId();
Все остальное хорошо.

2. Вы должны посмотреть: Error-Handling-Operators. В этом случае я бы посоветовал более подробно рассмотреть onErrorResumeNext( )

Надеюсь, это будет полезно.