Class StreamSubscriptionTimeoutSupport.NoopSubscriptionTimeout$

  • All Implemented Interfaces:
    Cancellable, java.io.Serializable, scala.Equals, scala.Product
    Enclosing interface:
    StreamSubscriptionTimeoutSupport

    public static class StreamSubscriptionTimeoutSupport.NoopSubscriptionTimeout$
    extends java.lang.Object
    implements Cancellable, scala.Product, java.io.Serializable
    INTERNAL API

    Subscription timeout which does not start any scheduled events and always returns true. This specialized implementation is to be used for "noop" timeout mode.

    See Also:
    Serialized Form
    • Constructor Detail

      • NoopSubscriptionTimeout$

        public NoopSubscriptionTimeout$()
    • Method Detail

      • cancel

        public boolean cancel()
        Description copied from interface: Cancellable
        Cancels this Cancellable and returns true if that was successful. If this cancellable was (concurrently) cancelled already, then this method will return false although isCancelled will return true.

        Java & Scala API

        Specified by:
        cancel in interface Cancellable
      • isCancelled

        public boolean isCancelled()
        Description copied from interface: Cancellable
        Returns true if and only if this Cancellable has been successfully cancelled

        Java & Scala API

        Specified by:
        isCancelled in interface Cancellable
      • productPrefix

        public java.lang.String productPrefix()
        Specified by:
        productPrefix in interface scala.Product
      • productArity

        public int productArity()
        Specified by:
        productArity in interface scala.Product
      • productElement

        public java.lang.Object productElement​(int x$1)
        Specified by:
        productElement in interface scala.Product
      • productIterator

        public scala.collection.Iterator<java.lang.Object> productIterator()
        Specified by:
        productIterator in interface scala.Product
      • canEqual

        public boolean canEqual​(java.lang.Object x$1)
        Specified by:
        canEqual in interface scala.Equals
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object