public final class RefCountSubscription extends Objectimplements Subscription
| Constructor and Description |
|---|
RefCountSubscription(Subscription
Creates a
RefCountSubscription by wrapping the given non-null
Subscription.
|
| Modifier and Type | Method and Description |
|---|---|
Subscription |
get()
Returns a new sub-subscription
|
boolean |
isUnsubscribed()
Indicates whether this
Subscription is currently unsubscribed.
|
void |
unsubscribe()
Stops the receipt of notifications on the
Subscriber that was registered when this Subscription was received.
|
public RefCountSubscription(Subscriptions)
RefCountSubscription by wrapping the given non-null
Subscription.
s - the
Subscription to wrap
IllegalArgumentException - if
s is
null
public Subscriptionget()
public boolean isUnsubscribed()
Subscription
Subscription is currently unsubscribed.
isUnsubscribed in interface
Subscription
true if this
Subscription is currently unsubscribed,
false otherwise
public void unsubscribe()
Subscription
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).