BitstampStreamingMarketDataService implements StreamingMarketDataService { public Observable<OrderBook> getDifferentialOrderBook(CurrencyPair currencyPair, Object... args) { return getOrderBook("diff_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 testGetDifferentialOrderBook() throws Exception { testOrderbookCommon( "diff_order_book_btceur", () -> marketDataService.getDifferentialOrderBook(CurrencyPair.BTC_EUR).test()); }