gistfile1.java

public class TownshipCloudDataStore implements TownshipDataStore {
    private final TownshipCache townshipCache;
    TownshipCloudDataStore(TownshipCache townshipCache){
        this.townshipCache = townshipCache;
    }
    @Override
    public Observable<List<TownshipEntity>> townships() {
        return ServiceGenerator.getTownshipService().getTownships().doOnNext(new Consumer<List<TownshipEntity>>() {
            @Override
            public void accept(final List<TownshipEntity> townshipEntities) throws Exception {
                townshipCache.put(townshipEntities);
            }
        });
    }
}