public class DropSubscription<O> extends PushSubscription<O>
- If no capacity (no previous request or capacity drained), drop data - If capacity (previous request and capacity remaining), call subscriber onNext
Each next signal will decrement the capacity by 1.
Modifier and Type | Field and Description |
---|---|
protected long |
capacity |
protected static AtomicLongFieldUpdater<DropSubscription> |
CAPACITY_UPDATER |
PENDING_UPDATER, pendingRequestSignals, publisher, subscriber, TERMINAL_UPDATER, terminated
Constructor and Description |
---|
DropSubscription(Stream<O> publisher,
org.reactivestreams.Subscriber<? super O> subscriber) |
Modifier and Type | Method and Description |
---|---|
void |
cancel() |
void |
onNext(O ev) |
void |
request(long elements) |
String |
toString() |
accept, equals, getPublisher, getSubscriber, hashCode, hasPublisher, isComplete, markAsDeferredStart, markAsStarted, maxCapacity, onComplete, onError, onRequest, pendingRequestSignals, shouldRequestPendingSignals, start, terminate, updatePendingRequests, wrap
protected volatile long capacity
protected static final AtomicLongFieldUpdater<DropSubscription> CAPACITY_UPDATER
public void request(long elements)
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 void onNext(O ev)
onNext
in class PushSubscription<O>
public String toString()
toString
in class PushSubscription<O>
Copyright © 2017. All rights reserved.