Package info.bitrich.xchangestream.coinmate.v2

Class CoinmateStreamingAccountService

java.lang.Object
info.bitrich.xchangestream.coinmate.v2.CoinmateStreamingAccountService
All Implemented Interfaces:
StreamingAccountService
public class CoinmateStreamingAccountService extends Object implements StreamingAccountService

  • Constructor Details

    • CoinmateStreamingAccountService

      public CoinmateStreamingAccountService(info.bitrich.xchangestream.coinmate.v2.CoinmateStreamingService coinmateStreamingService)

  • Method Details

    • getBalanceChanges

      public io.reactivex.rxjava3.core.Observable<Balance> getBalanceChanges(Currency currency, Object... args)
      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 interface StreamingAccountService
      Parameters:
      currency - Currency to monitor.
      Returns:
      Observable that emits Balance when exchange sends the update.

    • getWalletChanges

      public io.reactivex.rxjava3.core.Observable<Wallet> getWalletChanges(Object... args)