Interface ObserveHandle

    • Method Detail

      • isReadyForProcessing

        default boolean isReadyForProcessing()
        Verify if we can read without any (known in advance) delays defined by any possible ThroughputLimiter.
      • close

        void close()
        Stop the consumption.
        Specified by:
        close in interface java.lang.AutoCloseable
      • disableRateLimiting

        default void disableRateLimiting()
        Disable any rate limit for this handle.