public class RxMovieProxyExample extends AbstractRxMovieClient
RxMovieServer prior to running this example!NEW_LINE_SPLIT_RE, TEST_USER| Constructor and Description |
|---|
RxMovieProxyExample(int port) |
| Modifier and Type | Method and Description |
|---|---|
static void |
main(java.lang.String[] args) |
void |
shutdown() |
protected rx.Observable<io.netty.buffer.ByteBuf>[] |
triggerMoviesRegistration() |
protected rx.Observable<io.netty.buffer.ByteBuf>[] |
triggerRecommendationsSearch() |
protected rx.Observable<io.netty.buffer.ByteBuf>[] |
triggerRecommendationsUpdate() |
registerMovies, runExample, searchCatalog, updateRecommendationsprotected rx.Observable<io.netty.buffer.ByteBuf>[] triggerMoviesRegistration()
triggerMoviesRegistration in class AbstractRxMovieClientprotected rx.Observable<io.netty.buffer.ByteBuf>[] triggerRecommendationsUpdate()
triggerRecommendationsUpdate in class AbstractRxMovieClientprotected rx.Observable<io.netty.buffer.ByteBuf>[] triggerRecommendationsSearch()
triggerRecommendationsSearch in class AbstractRxMovieClientpublic void shutdown()
shutdown in class AbstractRxMovieClientpublic static void main(java.lang.String[] args)