Class GeminiStreamingExchange

    • Constructor Detail

      • GeminiStreamingExchange

        public GeminiStreamingExchange()
    • 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.
      • 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