@SuppressWarnings("unchecked")
    @Override
    protected Observable<ByteBuf>[] triggerRecommendationsUpdate() {
        return new Observable[]{
                updateRecommendationTemplate.requestBuilder()
                        .withRawContentSource(Observable.just(Movie.ORANGE_IS_THE_NEW_BLACK.getId()), new StringTransformer())
                        .withRequestProperty("userId", TEST_USER)
                        .build().toObservable(),
                updateRecommendationTemplate.requestBuilder()
                        .withRawContentSource(Observable.just(Movie.BREAKING_BAD.getId()), new StringTransformer())
                        .withRequestProperty("userId", TEST_USER)
                        .build().toObservable()
        };
    }
Run {@link com.netflix.ribbon.examples.rx.RxMovieServer} prior to runnng this example!

@author Tomasz Bak
ribbon-examples/src/main/java/com/netflix/ribbon/examples/rx/template/RxMovieTemplateExample.java