BitstampStreamingMarketDataService implements StreamingMarketDataService { @Override public Observable<Ticker> getTicker(CurrencyPair currencyPair, Object... args) { throw new NotAvailableFromExchangeException(); } 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(expected = NotAvailableFromExchangeException.class) public void testGetTicker() { marketDataService.getTicker(CurrencyPair.BTC_EUR).test(); }