public class WrappedSubscription<O> extends PushSubscription<O>
Modifier and Type | Field and Description |
---|---|
protected PushSubscription<O> |
pushSubscription |
protected org.reactivestreams.Subscription |
subscription |
PENDING_UPDATER, pendingRequestSignals, publisher, subscriber, TERMINAL_UPDATER, terminated
Constructor and Description |
---|
WrappedSubscription(org.reactivestreams.Subscription subscription,
org.reactivestreams.Subscriber<? super O> subscriber) |
Modifier and Type | Method and Description |
---|---|
void |
cancel() |
boolean |
equals(Object o) |
Stream<O> |
getPublisher() |
int |
hashCode() |
boolean |
hasPublisher() |
boolean |
isComplete() |
void |
maxCapacity(long n) |
protected void |
onRequest(long elements) |
void |
request(long n) |
boolean |
shouldRequestPendingSignals() |
String |
toString() |
void |
updatePendingRequests(long n) |
accept, getSubscriber, markAsDeferredStart, markAsStarted, onComplete, onError, onNext, pendingRequestSignals, start, terminate, wrap
protected final org.reactivestreams.Subscription subscription
protected final PushSubscription<O> pushSubscription
public WrappedSubscription(org.reactivestreams.Subscription subscription, org.reactivestreams.Subscriber<? super O> subscriber)
public void request(long n)
request
in interface org.reactivestreams.Subscription
request
in class PushSubscription<O>
public void cancel()
cancel
in interface org.reactivestreams.Subscription
cancel
in class PushSubscription<O>
public final Stream<O> getPublisher()
getPublisher
in class PushSubscription<O>
public void maxCapacity(long n)
maxCapacity
in class PushSubscription<O>
public void updatePendingRequests(long n)
updatePendingRequests
in class PushSubscription<O>
public boolean shouldRequestPendingSignals()
shouldRequestPendingSignals
in class PushSubscription<O>
public boolean isComplete()
isComplete
in class PushSubscription<O>
protected final void onRequest(long elements)
onRequest
in class PushSubscription<O>
public final boolean equals(Object o)
equals
in class PushSubscription<O>
public final boolean hasPublisher()
hasPublisher
in class PushSubscription<O>
public final int hashCode()
hashCode
in class PushSubscription<O>
public String toString()
toString
in class PushSubscription<O>
Copyright © 2016. All rights reserved.