@SuppressWarnings("unchecked")
    @Override
    protected Observable<ByteBuf>[] triggerMoviesRegistration() {
        return new Observable[]{
                movieService.registerMovie(Movie.ORANGE_IS_THE_NEW_BLACK).toObservable(),
                movieService.registerMovie(Movie.BREAKING_BAD).toObservable(),
                movieService.registerMovie(Movie.HOUSE_OF_CARDS).toObservable()
        };
    }
Run {@link com.netflix.ribbon.examples.rx.RxMovieServer} prior to running this example!

@author Tomasz Bak
ribbon-examples/src/main/java/com/netflix/ribbon/examples/rx/proxy/RxMovieProxyExample.java