XChange is a Java library providing a streamlined API for interacting with 60+ Bitcoin and Altcoin exchanges providing a consistent interface for trading and accessing market data.
I got error when using getTrades function of OkexStreamingExchange. Please help me
StreamingExchange exchange = StreamingExchangeFactory.INSTANCE.createExchange(OkexStreamingExchange.class); exchange.connect().blockingAwait(); StreamingMarketDataService service = exchange .getStreamingMarketDataService(); Disposable subscriptionTrade = service .getTrades(currencyPair) .subscribe(trade -> log.info("Trade: {}", trade), throwable -> log.error("Error in trade subscription", throwable));
I got error when using getTrades function of OkexStreamingExchange. Please help me
StreamingExchange exchange = StreamingExchangeFactory.INSTANCE.createExchange(OkexStreamingExchange.class); exchange.connect().blockingAwait(); StreamingMarketDataService service = exchange .getStreamingMarketDataService(); Disposable subscriptionTrade = service .getTrades(currencyPair) .subscribe(trade -> log.info("Trade: {}", trade), throwable -> log.error("Error in trade subscription", throwable));