StoreRepository.java

class StoreRepository {
  Observable<Lce<List<Store>> getStoreEventStream() {
    return userBundleManager.switchMap { bundleEvent ->
      if (bundleEvent.isLoading()) {
        return Observable.just(Lce.loading())
      } else if (bundleEvent.hasError()) {
        return Observable.just(Lce.error(bundleEvent.getError()))
      } else {
       // Stores can come from cached source or network
       return storeListEventStream(bundleEvent.data.getZipCode())
      }
   }
}