com.netflix.ribbon.examples.rx.transport

Class RxMovieTransportExample

java.lang.Object

com.netflix.ribbon.examples.rx.AbstractRxMovieClient

com.netflix.ribbon.examples.rx.transport.RxMovieTransportExample

public class RxMovieTransportExample
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
RxMovieTransportExample(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

RxMovieTransportExample

public RxMovieTransportExample(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)