Class DelayedSubscription
- java.lang.Object
-
- io.servicetalk.concurrent.internal.DelayedSubscription
-
- All Implemented Interfaces:
Cancellable,PublisherSource.Subscription
public final class DelayedSubscription extends java.lang.Object implements PublisherSource.Subscription
APublisherSource.Subscriptionwhich serves as a placeholder until the "real"PublisherSource.Subscriptionis available.
-
-
Field Summary
-
Fields inherited from interface io.servicetalk.concurrent.Cancellable
IGNORE_CANCEL
-
-
Constructor Summary
Constructors Constructor Description DelayedSubscription()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidcancel()Sends a hint to the producer of the associated asynchronous execution that the consumer related to thisCancellableis not interested in the outcome of the execution.voiddelayedSubscription(PublisherSource.Subscription delayedSubscription)Set the delayedPublisherSource.Subscription.voidrequest(long n)Requestsnmore items from the associatedPublisherSourcefor the associatedPublisherSource.Subscriber.
-
-
-
Method Detail
-
delayedSubscription
public void delayedSubscription(PublisherSource.Subscription delayedSubscription)
Set the delayedPublisherSource.Subscription. This method can only be called a single time and subsequent calls will result incancel()being called ondelayedSubscription.- Parameters:
delayedSubscription- The delayedPublisherSource.Subscription.
-
request
public void request(long n)
Description copied from interface:PublisherSource.SubscriptionRequestsnmore items from the associatedPublisherSourcefor the associatedPublisherSource.Subscriber.See Reactive Streams specifications for the rules about how and when this method will be invoked.
- Specified by:
requestin interfacePublisherSource.Subscription- Parameters:
n- Number of items to request.
-
cancel
public void cancel()
Description copied from interface:CancellableSends a hint to the producer of the associated asynchronous execution that the consumer related to thisCancellableis not interested in the outcome of the execution.- Specified by:
cancelin interfaceCancellable
-
-