Package rx

Class SingleSubscriber<T>

    • Method Summary

      All Methods Instance Methods Abstract Methods Concrete Methods 
      Modifier and Type Method Description
      void add​(Subscription s)
      Adds a Subscription to this Subscriber's list of subscriptions if this list is not marked as unsubscribed.
      boolean isUnsubscribed()
      Indicates whether this Subscriber has unsubscribed from its list of subscriptions.
      abstract void onError​(java.lang.Throwable error)
      Notifies the SingleSubscriber that the Single has experienced an error condition.
      abstract void onSuccess​(T value)
      Notifies the SingleSubscriber with a single item and that the Single has finished sending push-based notifications.
      void unsubscribe()
      Stops the receipt of notifications on the Subscriber that was registered when this Subscription was received.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • SingleSubscriber

        public SingleSubscriber()
    • Method Detail

      • onSuccess

        public abstract void onSuccess​(T value)
        Notifies the SingleSubscriber with a single item and that the Single has finished sending push-based notifications.

        The Single will not call this method if it calls onError(java.lang.Throwable).

        Parameters:
        value - the item emitted by the Single
      • onError

        public abstract void onError​(java.lang.Throwable error)
        Notifies the SingleSubscriber that the Single has experienced an error condition.

        If the Single calls this method, it will not thereafter call onSuccess(T).

        Parameters:
        error - the exception encountered by the Single
      • add

        public final void add​(Subscription s)
        Adds a Subscription to this Subscriber's list of subscriptions if this list is not marked as unsubscribed. If the list is marked as unsubscribed, add will indicate this by explicitly unsubscribing the new Subscription as well.
        Parameters:
        s - the Subscription to add
      • unsubscribe

        public final void unsubscribe()
        Description copied from interface: Subscription
        Stops the receipt of notifications on the Subscriber that was registered when this Subscription was received.

        This allows unregistering an Subscriber before it has finished receiving all events (i.e. before onCompleted is called).

        Specified by:
        unsubscribe in interface Subscription
      • isUnsubscribed

        public final boolean isUnsubscribed()
        Indicates whether this Subscriber has unsubscribed from its list of subscriptions.
        Specified by:
        isUnsubscribed in interface Subscription
        Returns:
        true if this Subscriber has unsubscribed from its subscriptions, false otherwise