- All Implemented Interfaces:
public class BinanceStreamingAccountService extends Object implements StreamingAccountService
Constructors Constructor Description
Modifier and Type Method Description
Currency currency, Object... args)(Get the changes of account balance for the logged-in user.
()Registers subsriptions with the streaming service for the given products.
BinanceStreamingAccountServicepublic BinanceStreamingAccountService(BinanceUserDataStreamingService binanceUserDataStreamingService)
getRawAccountInfopublic io.reactivex.Observable<OutboundAccountPositionBinanceWebsocketTransaction> getRawAccountInfo()
getBalanceChangespublic io.reactivex.Observable<Balance> getBalanceChanges()
getBalanceChangesDescription copied from interface:
StreamingAccountServiceGet 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
NotConnectedExceptionWhen not connected to the WebSocket API.
ExchangeSecurityExceptionif called without authentication details
openSubscriptionspublic void openSubscriptions()Registers subsriptions with the streaming service for the given products.
As we receive messages as soon as the connection is open, we need to register subscribers to handle these before the first messages arrive.