EnhancedMyStuffRepository.java

Observable<MyStuff> myStuffRepository = Observable
   .merge(savedJobPostingRepository.onErrorReturn(error -> null),
                    appliedJobPostingRepository.retry(1))
   .reduce(new MyStuff(), (accumulated, item) -> {
     switch (item.getEntityType()) {
       case SavedJobs:
         accumulated.savedJobPostings = item;
         break;
       case AppliedJobs:
         accumulated.appliedJobPostings = item;
         break;
     }
     return accumulated;
   });