public interface NonBlocking
Modifier and Type | Method and Description |
---|---|
long |
getCapacity()
Return defined element capacity, used to drive new
Subscription
request needs. |
boolean |
isReactivePull(Dispatcher dispatcher,
long producerCapacity)
Get the assigned
Dispatcher . |
boolean isReactivePull(Dispatcher dispatcher, long producerCapacity)
Dispatcher
.long getCapacity()
Subscription
request needs. This is the maximum in-flight data allowed to transit to this elements.Copyright © 2016. All rights reserved.