Class BitflyerStreamingExchange

    • Constructor Detail

      • BitflyerStreamingExchange

        public BitflyerStreamingExchange()
    • Method Detail

      • connect

        public io.reactivex.Completable connect​(ProductSubscription... args)
        Description copied from interface: StreamingExchange
        Connects to the WebSocket API of the exchange.
        Specified by:
        connect in interface StreamingExchange
        Parameters:
        args - Product subscription is used only in certain exchanges where you need to specify subscriptions during the connect phase.
        Returns:
        Completable that completes upon successful connection.
      • disconnect

        public io.reactivex.Completable disconnect()
        Description copied from interface: StreamingExchange
        Disconnect from the WebSocket API.
        Specified by:
        disconnect in interface StreamingExchange
        Returns:
        Completable that completes upon successful disconnect.
      • getNonceFactory

        public si.mazi.rescu.SynchronizedValueFactory<Long> getNonceFactory()
        Description copied from interface: Exchange
        The nonce factory used to create a nonce value. Allows services to accept a placeholder that is replaced with generated value just before message is serialized and sent. If a method of a rest accepts ValueFactory as a parameter, it's evaluated, the message is serialized and sent in a single synchronized block.
        Specified by:
        getNonceFactory in interface Exchange
        Overrides:
        getNonceFactory in class BitflyerExchange
        Returns:
        Synchronized value factory
      • isAlive

        public boolean isAlive()
        Description copied from interface: StreamingExchange
        Checks whether connection to the exchange is alive.
        Specified by:
        isAlive in interface StreamingExchange
        Returns:
        true if connection is open, otherwise false.
      • useCompressedMessages

        public void useCompressedMessages​(boolean compressedMessages)
        Description copied from interface: StreamingExchange
        Set whether or not to enable compression handler.
        Specified by:
        useCompressedMessages in interface StreamingExchange
        Parameters:
        compressedMessages - Defaults to false