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.Subscription
which serves as a placeholder until the "real"PublisherSource.Subscription
is 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 void
cancel()
Sends a hint to the producer of the associated asynchronous execution that the consumer related to thisCancellable
is not interested in the outcome of the execution.void
delayedSubscription(PublisherSource.Subscription delayedSubscription)
Set the delayedPublisherSource.Subscription
.void
request(long n)
Requestsn
more items from the associatedPublisherSource
for 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.Subscription
Requestsn
more items from the associatedPublisherSource
for the associatedPublisherSource.Subscriber
.See Reactive Streams specifications for the rules about how and when this method will be invoked.
- Specified by:
request
in interfacePublisherSource.Subscription
- Parameters:
n
- Number of items to request.
-
cancel
public void cancel()
Description copied from interface:Cancellable
Sends a hint to the producer of the associated asynchronous execution that the consumer related to thisCancellable
is not interested in the outcome of the execution.- Specified by:
cancel
in interfaceCancellable
-
-