MartinHarkins

ConnectableObservable<Wrapper<List<Data>>> dataObservable;

public Observable<Wrapper<List<Data>>> getData() {
   if (dataObservable == null) {
       dataObservable = webService.getApiData()
               .compose((Observable.Transformer<List<Data>, List<Data>>) networkScheduling)
               .map(dataList -> Wrapper.response(dataList))
               // Retry a few times before letting an error through.
               .retry(5) 
               .onErrorResumeNext(throwable -> {

MartinHarkins

// Use Gists to store code you would like to remember later on
console.log(window); // log the "window" object to the console