Advertisement
Heruberuto

Untitled

May 15th, 2017
50
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Java 0.54 KB | None | 0 0
  1. private static IResponse getResponse(IRequest newRequest) {
  2.         return (IResponse) Observable.concat(
  3.                 Observable.just(newRequest)
  4.                         .map(r ->Try.of(()->cacheResource.getResponse(r)))
  5.                         .filter(Try::isSuccess)
  6.                         .map(Try::get),
  7.                 Observable.just(newRequest)
  8.                         .map(r ->Try.of(()->fileResource.getResponse(r)))
  9.                         .filter(Try::isSuccess)
  10.                         .map(Try::get)
  11.         ).first(null);
  12.     }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement