Class CoinmateStreamingAccountService
java.lang.Object
info.bitrich.xchangestream.coinmate.v2.CoinmateStreamingAccountService
- All Implemented Interfaces:
StreamingAccountService
public class CoinmateStreamingAccountService extends Object implements StreamingAccountService
-
Constructor Summary
Constructors Constructor Description CoinmateStreamingAccountService(info.bitrich.xchangestream.coinmate.v2.CoinmateStreamingService coinmateStreamingService)
-
Method Summary
Modifier and Type Method Description io.reactivex.Observable<Balance>
getBalanceChanges(Currency currency, Object... args)
Get the changes of account balance for the logged-in user.io.reactivex.Observable<Wallet>
getWalletChanges(Object... args)
-
Constructor Details
-
CoinmateStreamingAccountService
public CoinmateStreamingAccountService(info.bitrich.xchangestream.coinmate.v2.CoinmateStreamingService coinmateStreamingService)
-
-
Method Details
-
getBalanceChanges
Description copied from interface:StreamingAccountService
Get the changes of account balance for the logged-in user.Warning: there are currently no guarantees that messages will arrive in order, that messages will not be skipped, or that any initial state message will be sent on connection. Most exchanges have a recommended approach for managing this, involving timestamps, sequence numbers and a separate REST API for re-sync when inconsistencies appear. You should implement these approaches, if required, by combining calls to this method with
AccountService.getAccountInfo()
.Emits
NotConnectedException
When not connected to the WebSocket API.Immediately throws
ExchangeSecurityException
if called without authentication details- Specified by:
getBalanceChanges
in interfaceStreamingAccountService
- Parameters:
currency
- Currency to monitor.- Returns:
Observable
that emitsBalance
when exchange sends the update.
-
getWalletChanges
-