別のスレッドでonNextを呼び出す（RxJava Android）

Question

オブジェクト（都市）を受け取って、このデータを別のスレッド（モバイル画面に反映してこの都市をDBに保存）に送りたい。これは私のコードです：

private CompositeSubscription subscriptions; 
    ... 
     @Override 
      public void onAddButtonClick(String cityName) { 
       Observable<City> obs = repository.getCity(cityName); 
       if (obs != null){ 
        Subscription subscription = obs 
          .subscribeOn(backgroundThread) 
          .observeOn(mainThread) 
          .subscribe(
            city -> { 
             view.cityExists(); 
             repository.saveCityToDb(city); 
            } 

          ); 

        subscriptions.add(subscription);  
       } else { 
        view.showCouldNotFindCity(); 
       }  
      } 

    @Override 
    public void subscribe() { 
     subscriptions = new CompositeSubscription(); 
    } 

    @Override 
    public void unsubscribe() { 
     subscriptions.clear(); 
    } 

だから私は、バックグラウンドスレッドでUIスレッドとrepository.saveCityToDb(city);上で実行したいview.cityExists();この方法。どうしたらいいですか？ Observable<City>を返しgetCity(...);

方法：これはトリックを行う必要があります

は

public Observable<City> getCity(String name){ 
     return fileRepository.getCityFromFile(name); 
    } 

Answer 1

あなたはflatMapオペレータのために見えるかもしれません。 Observableと同じスレッドで操作できます（Observableを変換します）。

Subscription subscription = obs 
    .subscribeOn(backgroundThread) 
    .flatMap(repository::saveCityToDb) 
    .observeOn(mainThread) 
    .subscribe(city -> view.cityExists()); 

機能

repository::saveCityToDb

がObservableを継続するために何かを返さなければならないことを、覚えておいてください。私はオブジェクトObservable.just(city)を返すことを提案します。

Answer 2

：

Subscription subscription = obs 
     .subscribeOn(backgroundThread) 
     .doOnNext(city -> view.cityExists()) 
     .observeOn(mainThread) 
     .subscribe(repository::saveCityToDb);