RxCache.java

//read from loader
    api
      .compose(rxCache.<User>.read("mock").toObservable())
      .subscribe();
    
    //read without loader
    RxCache.<User>.read("mock")
        .toObservable()
        .subscribe();
      
    //add
    Observable.just(mock)
      .compose(rxCache.<User>.read("mock")
        .evict(true)
        .fromObservable())
      .subscribe();
    
    //update
    
    rxCache.<Mock>read("mock")
        .toObservable()
        .map(user -> {
          user.setMessage("hola");
          return user;
        })
        .compose(rxCache.<Mock>read("mock")
            .evict(true)
            .fromObservable())
        .subscribe(subscriber);
        
    //remove     
    rxCache.<Mock>read("mock")
        .toObservable()
        .map(user -> null)
        .compose(rxCache.<Mock>read("mock").evict(true)
            .fromObservable())
        .subscribe(subscriber);