Class BitfinexStreamingTradeService

    • Method Detail

      • getOrderChanges

        public io.reactivex.Observable<Order> getOrderChanges()
      • getOrderChanges

        public io.reactivex.Observable<Order> getOrderChanges​(CurrencyPair currencyPair,
                                                              Object... args)
        Description copied from interface: StreamingTradeService
        Get the changes of order state 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 TradeService.getOpenOrders().

        Emits NotConnectedException When not connected to the WebSocket API.

        Immediately throws ExchangeSecurityException if called without authentication details

        Specified by:
        getOrderChanges in interface StreamingTradeService
        Parameters:
        currencyPair - Currency pair of the order changes.
        Returns:
        Observable that emits Order when exchange sends the update.
      • getUserTrades

        public io.reactivex.Observable<UserTrade> getUserTrades()
        Gets a stream of all user trades to which we are subscribed.
        Returns:
        The stream of user trades.