Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 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;
- });
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement