Enum EmptySubscription

    • Enum Constant Detail

      • INSTANCE

        public static final EmptySubscription INSTANCE
        A singleton, stateless instance.
    • Method Detail

      • values

        public static EmptySubscription[] values()
        Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows:
        for (EmptySubscription c : EmptySubscription.values())
            System.out.println(c);
        
        Returns:
        an array containing the constants of this enum type, in the order they are declared
      • valueOf

        public static EmptySubscription valueOf​(String name)
        Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are not permitted.)
        Parameters:
        name - the name of the enum constant to be returned.
        Returns:
        the enum constant with the specified name
        Throws:
        IllegalArgumentException - if this enum type has no constant with the specified name
        NullPointerException - if the argument is null
      • request

        public void request​(long n)
        Specified by:
        request in interface org.reactivestreams.Subscription
      • cancel

        public void cancel()
        Specified by:
        cancel in interface org.reactivestreams.Subscription
      • error

        public static void error​(Throwable e,
                                 org.reactivestreams.Subscriber<?> s)
        Sets the empty subscription instance on the subscriber and then calls onError with the supplied error.

        Make sure this is only called if the subscriber hasn't received a subscription already (there is no way of telling this).

        Parameters:
        e - the error to deliver to the subscriber
        s - the target subscriber
      • complete

        public static void complete​(org.reactivestreams.Subscriber<?> s)
        Sets the empty subscription instance on the subscriber and then calls onComplete.

        Make sure this is only called if the subscriber hasn't received a subscription already (there is no way of telling this).

        Parameters:
        s - the target subscriber