Adds a tear down to be called during the unsubscribe() of this Subscription.
If the tear down being added is a subscription that is already
unsubscribed, is the same reference add is being called on, or is
Subscription.EMPTY, it will not be added.
If this subscription is already in an closed state, the passed
tear down logic will be executed immediately.
The additional logic to execute on teardown.
Returns the Subscription used or created to be
added to the inner subscriptions list. This Subscription can be used with
remove() to remove the passed teardown logic from the inner subscriptions
list.
The {@link Observer} callback to receive a valueless notification of type
complete from the Observable. Notifies the Observer that the Observable
has finished sending push-based notifications.
The {@link Observer} callback to receive notifications of type error from
the Observable, with an attached Error. Notifies the Observer that
the Observable has experienced an error condition.
The {@link Observer} callback to receive notifications of type next from
the Observable, with a value. The Observable may call this method 0 or more
times.
Removes a Subscription from the internal list of subscriptions that will unsubscribe during the unsubscribe process of this Subscription.
The subscription to remove.
A static factory for a Subscriber, given a (potentially partial) definition of an Observer.
A Subscriber wrapping the (partially defined) Observer represented by the given arguments.
A flag to indicate whether this Subscription has already been unsubscribed.
{boolean}