com.netflix.ribbon.examples.rx.template

Class RxMovieTemplateExample

java.lang.Object

com.netflix.ribbon.examples.rx.AbstractRxMovieClient

com.netflix.ribbon.examples.rx.template.RxMovieTemplateExample

public class RxMovieTemplateExample
extends AbstractRxMovieClient

Run RxMovieServer prior to runnng this example!

Field Summary

Fields inherited from class com.netflix.ribbon.examples.rx.AbstractRxMovieClient

NEW_LINE_SPLIT_RE, TEST_USER

Constructor Summary

Constructors

Constructor and Description
RxMovieTemplateExample(int port)

Method Summary

Modifier and Type	Method and Description
static void	main(java.lang.String[] args)
protected rx.Observable<io.netty.buffer.ByteBuf>[]	triggerMoviesRegistration()
protected rx.Observable<io.netty.buffer.ByteBuf>[]	triggerRecommendationsSearch()
protected rx.Observable<io.netty.buffer.ByteBuf>[]	triggerRecommendationsUpdate()

Methods inherited from class com.netflix.ribbon.examples.rx.AbstractRxMovieClient

registerMovies, runExample, searchCatalog, shutdown, updateRecommendations

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RxMovieTemplateExample

public RxMovieTemplateExample(int port)

Method Detail

triggerMoviesRegistration

protected rx.Observable<io.netty.buffer.ByteBuf>[] triggerMoviesRegistration()

Specified by:

triggerMoviesRegistration in class AbstractRxMovieClient

triggerRecommendationsUpdate

protected rx.Observable<io.netty.buffer.ByteBuf>[] triggerRecommendationsUpdate()

Specified by:

triggerRecommendationsUpdate in class AbstractRxMovieClient

triggerRecommendationsSearch

protected rx.Observable<io.netty.buffer.ByteBuf>[] triggerRecommendationsSearch()

Specified by:

triggerRecommendationsSearch in class AbstractRxMovieClient

main

public static void main(java.lang.String[] args)