RxJava：在Observable.just之後它仍然調用Observable.empty（）

Question

我想通過名稱從文件中檢索特定的城市。如果未找到該城市，則返回Observable.empty（）;否則我會返回Observable.just（城市）; 下面是代碼：

public void onAddButtonClick(String cityName) { 
     Subscription subscription = repository.getCity(cityName)   
       .subscribeOn(backgroundThread) 
       .flatMap(city -> repository.saveCityToDb(city)) 
       .observeOn(mainThread)  
       .subscribe(
         city -> view.cityExists(), 
         throwable -> view.showCouldNotFindCity(), 
         () -> view.showCouldNotFindCity() 
       ); 

     subscriptions.add(subscription); 
    } 

和方法getCity()：

public Observable<City> getCity(String cityName){ 
     return Observable.defer(() -> { 
      try { 
       InputStream is = assetManager.open(FILE_NAME); 
       Scanner scanner = new Scanner(is); 
       while (scanner.hasNextLine()) { 
        String line = scanner.nextLine(); 
        if (line.toLowerCase().contains(cityName.toLowerCase())) { 
         String[] cityParams = line.split("\t"); 
         City city = new City(); 
         city.setId(Long.parseLong(cityParams[0])); 
         city.setName(cityParams[1]); 
         return Observable.just(city); 
        } 
       } 

      } catch (IOException e) { 
       return Observable.error(e); 
      }   
      return Observable.empty(); 
     }); 
    } 

但是，當城市發現的問題是，它去return Observable.empty();我不知道爲什麼它返回Observable.just(city);。所以代碼() -> view.showCouldNotFindCity()被稱爲無論如何。

Answer 1

問題是你在onCompleted處理程序中調用this（） - > view.showCouldNotFindCity（）。如果你看看RxJava中的just（）方法，你會看到它首先調用onNext，然後調用訂閱者上的onCompleted方法。所以當發現城市時 - > view.cityExists（）被調用，然後立即在（） - > view.showCouldNotFindCity（）之後。

如果在您的getCity方法中找不到城市，我只會拋出一個錯誤。由於你的onError已經調用了desired（） - > view.showCouldNotFindCity（）方法並將它從onCompleted處理程序中移除。