public final class BatchSubscription<T> extends WrappedSubscription<T>
pushSubscription, subscription
PENDING_UPDATER, pendingRequestSignals, publisher, subscriber, TERMINAL_UPDATER, terminated
Constructor and Description |
---|
BatchSubscription(org.reactivestreams.Subscription subscription,
org.reactivestreams.Subscriber<T> subscriber,
int batchSize) |
Modifier and Type | Method and Description |
---|---|
void |
request(long n) |
cancel, equals, getPublisher, hashCode, hasPublisher, isComplete, maxCapacity, onRequest, shouldRequestPendingSignals, toString, updatePendingRequests
accept, getSubscriber, markAsDeferredStart, markAsStarted, onComplete, onError, onNext, pendingRequestSignals, start, terminate, wrap
public BatchSubscription(org.reactivestreams.Subscription subscription, org.reactivestreams.Subscriber<T> subscriber, int batchSize)
public void request(long n)
request
in interface org.reactivestreams.Subscription
request
in class WrappedSubscription<T>
Copyright © 2017. All rights reserved.