public abstract class AbstractRxMovieClient
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
protected static java.util.regex.Pattern |
NEW_LINE_SPLIT_RE |
protected static java.lang.String |
TEST_USER |
| Constructor and Description |
|---|
AbstractRxMovieClient() |
| Modifier and Type | Method and Description |
|---|---|
protected rx.Observable<io.netty.buffer.ByteBuf> |
registerMovies() |
boolean |
runExample() |
protected rx.Observable<java.lang.Void> |
searchCatalog() |
protected void |
shutdown() |
protected abstract rx.Observable<io.netty.buffer.ByteBuf>[] |
triggerMoviesRegistration() |
protected abstract rx.Observable<io.netty.buffer.ByteBuf>[] |
triggerRecommendationsSearch() |
protected abstract rx.Observable<io.netty.buffer.ByteBuf>[] |
triggerRecommendationsUpdate() |
protected rx.Observable<io.netty.buffer.ByteBuf> |
updateRecommendations() |
protected static final java.lang.String TEST_USER
protected static final java.util.regex.Pattern NEW_LINE_SPLIT_RE
protected abstract rx.Observable<io.netty.buffer.ByteBuf>[] triggerMoviesRegistration()
protected abstract rx.Observable<io.netty.buffer.ByteBuf>[] triggerRecommendationsUpdate()
protected abstract rx.Observable<io.netty.buffer.ByteBuf>[] triggerRecommendationsSearch()
protected rx.Observable<io.netty.buffer.ByteBuf> registerMovies()
protected rx.Observable<io.netty.buffer.ByteBuf> updateRecommendations()
protected rx.Observable<java.lang.Void> searchCatalog()
public boolean runExample()
protected void shutdown()