/**
* Метод, который сразу возвращает значение, если оно
* доступно, или использует  другой поток исполнения,
* чтобы получить значение и передать его через callback `onNext()`
*/
public Observable<T> getProduct(String name) {
    if (productInCache(name)) {
        // Если данные доступны, возвращаем их сразу
        return Observable.create(observer -> {
           observer.onNext(getProductFromCache(name));
           observer.onComplete();
        });
    } else {
        // Иначе задействуем другой поток исполнения
        return Observable.<T>create(observer -> {
            try {
                // Выполняем работу в отдельном потоке
                T product = getProductFromRemoteService(name);
                // вовращаем значение
                observer.onNext(product);
                observer.onComplete();
            } catch (Exception e) {
                observer.onError(e);
            }
        })
        // Говорим Observable использовать планировщик IO
        // для создания/получения данных
        .subscribeOn(Schedulers.io());
    }
}

saveProductInteractor.execute(product, new ObserverEntity<Void>() {
    @Override
    public void onNext(Void aVoid) {
        // Сейчас этот метод нам не нужен,
        // но мы обязана его реализовать
    }
    @Override
    public void onError(Throwable throwable) {
        // Сейчас этот метод используется
        // Какой-то код
    }
    @Override
    public void onComplete() {
        // И этот метод тоже используется
        // Какой-то код
    }
});

private void checkProduct(int id, Locale locale) {
    getProductByIdInteractor.execute(new TypesUtil.Pair<>(id, locale), new ObserverEntity<Product>() {
        @Override
        public void onNext(Product product) {
            getProductInfo(product);
        }
        @Override
        public void onError(Throwable throwable) {
            // Какой-то код
        }
        @Override
        public void onComplete() {
        }
    });
}
private void getProductInfo(Product product) {
    getReviewsByProductIdInteractor.execute(product.getId(), new ObserverEntity<List<Review>>() {
        @Override
        public void onNext(List<Review> reviews) {
            product.setReviews(reviews);
            saveProduct(productInfo);
        }
        @Override
        public void onError(Throwable throwable) {
            // Какой-то код
        }
        @Override
        public void onComplete() {
            // Какой-то код
        }
    });
    getImageForProductInteractor.execute(product.getId(), new ObserverEntity<Image>() {
        @Override
        public void onNext(Image image) {
            product.setImage(image);
            saveProduct(product);
        }
        @Override
        public void onError(Throwable throwable) {
            // Какой-то код
        }
        @Override
        public void onComplete() {
        }
    });
}
private void saveProduct(Product product) {
    saveProductInteractor.execute(product, new ObserverEntity<Void>() {
        @Override
        public void onNext(Void aVoid) {
        }
        @Override
        public void onError(Throwable throwable) {
            // Какой-то код
        }
        @Override
        public void onComplete() {
            goToSomeScreen();
        }
    });
}

private Observable<Product> getProductById(int id, Locale locale) {
    return getProductByIdInteractor.execute(new TypesUtil.Pair<>(id, locale));
}
private Observable<Product> getProductInfo(Product product) {
    return getReviewsByProductIdInteractor.execute(product.getId())
    .map(reviews -> {
        product.set(reviews);
        return product;
    })
    .flatMap(product -> {
        getImageForProductInteractor.execute(product.getId())
        .map(image -> {
            product.set(image);
            return product;
        })
    });
}
private Observable<Product> saveProduct(Product product) {
    return saveProductInteractor.execute(product);
}
private doAll(int id, Locale locale) {
    // Берем продукт из хранилища
    getProductById (id, locale)
    // Добавляем информацию
    .flatMap(product -> getProductInfo(product))
    // Сохраняем все в другое хранилище
    .flatMap(product -> saveProduct(product))
    // После сохранения продукты в потоке больше не нужны
    .ignoreElements()
    // Устанавливаем планировщики
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    // Переходим на другой экран
    .subscribe(() -> goToSomeScreen(), throwable -> handleError());
}