@SuppressWarnings("unchecked")
    @Override
    protected Observable<ByteBuf>[] triggerRecommendationsUpdate() {
        return new Observable[]{
                updateRecommendation(TEST_USER, Movie.ORANGE_IS_THE_NEW_BLACK),
                updateRecommendation(TEST_USER, Movie.BREAKING_BAD)
        };
    }
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/transport/RxMovieTransportExample.java