public abstract static class FanInAction.InnerSubscriber<I,E,O> extends Object implements org.reactivestreams.Subscriber<I>, NonBlocking, Consumer<Long>
Modifier and Type | Method and Description |
---|---|
void |
accept(Long pendingRequests)
Execute the logic of the action, accepting the given parameter.
|
void |
cancel() |
long |
getCapacity()
Return defined element capacity, used to drive new
Subscription
request needs. |
boolean |
isReactivePull(Dispatcher dispatcher,
long producerCapacity)
Get the assigned
Dispatcher . |
void |
onComplete() |
void |
onError(Throwable t) |
void |
request(long n) |
String |
toString() |
public void cancel()
public void accept(Long pendingRequests)
Consumer
public void request(long n)
public void onError(Throwable t)
onError
in interface org.reactivestreams.Subscriber<I>
public void onComplete()
onComplete
in interface org.reactivestreams.Subscriber<I>
public boolean isReactivePull(Dispatcher dispatcher, long producerCapacity)
NonBlocking
Dispatcher
.isReactivePull
in interface NonBlocking
public long getCapacity()
NonBlocking
Subscription
request needs. This is the maximum in-flight data allowed to transit to this elements.getCapacity
in interface NonBlocking
Copyright © 2016. All rights reserved.