@Test @Ignore public void should_send_a_stock_message_when_receiving_a_quote() { Observable<String> quoteSource = hot("--q--", of("q", new Quote("GOOGL", 705.8673).toJson())); StockServer server = createServer(quoteSource); expectObservable(server.getEvents(null).map(s -> s.companyName).concatWith(Observable.never())) .toBe("--s--", of("s", "Alphabet Inc")); }
@Override protected Observable<Stock> getEvents(HttpRequest request) { return Observable.never(); }
StockServer extends RxNettyEventServer<Stock> { @Override protected Observable<Stock> getEvents(HttpRequest request) { return Observable.never(); } }
StockServer extends RxNettyEventServer<Stock> { @Override protected Observable<Stock> getEvents(HttpRequest request) { return Observable.never(); } StockServer(int port,
                       RequestReplyClient stockClient,
                       EventStreamClient quoteEventStreamClient,
                       Scheduler scheduler); }
StockServer extends RxNettyEventServer<Stock> { @Override protected Observable<Stock> getEvents(HttpRequest request) { return Observable.never(); } StockServer(int port,
                       RequestReplyClient stockClient,
                       EventStreamClient quoteEventStreamClient,
                       Scheduler scheduler);  }
StockServer extends RxNettyEventServer<Stock> { @Override protected Observable<Stock> getEvents(HttpRequest request) { return Observable.never(); } StockServer(int port,
                       RequestReplyClient stockClient,
                       EventStreamClient quoteEventStreamClient,
                       Scheduler scheduler);   }