BitstampStreamingMarketDataService implements StreamingMarketDataService { @Override public Observable<OrderBook> getOrderBook(CurrencyPair currencyPair, Object... args) { return getOrderBook("order_book", currencyPair, args); } BitstampStreamingMarketDataService(PusherStreamingService service); Observable<OrderBook> getDifferentialOrderBook(CurrencyPair currencyPair, Object... args); @Override Observable<OrderBook> getOrderBook(CurrencyPair currencyPair, Object... args); @Override Observable<Ticker> getTicker(CurrencyPair currencyPair, Object... args); @Override Observable<Trade> getTrades(CurrencyPair currencyPair, Object... args);  }
@Test public void testGetOrderBook() throws Exception { testOrderbookCommon( "order_book_btceur", () -> marketDataService.getOrderBook(CurrencyPair.BTC_EUR).test()); }