public static interface DemandAware.Sink
DemandAware.Sinkthat accepts data. It can signal its
DemandAware.Sourcedemand/readiness to emit more data. Instances of implementing classes are required to be thread-safe as they are shared amongst multiple threads.
|Modifier and Type||Method and Description|
Returns true if the
DemandAware.Sinkhas demand or false if the source has no demand. false means either the
DemandAware.Sinkhas no demand in general because data is not needed or the current demand is saturated.
void setSource(DemandAware.Source source)
DemandAware.Sinkis notified by this
DemandAware.Sourceif the source indicates new demand or the sink catches up so it's ready to receive more data.
source- the reference to the data
DemandAware.Source, must not be null.
DemandAware.Sourcereference from this
DemandAware.Sink. Any previously set
DemandAware.Sourcewill no longer be asked for data.
Copyright © 2019 lettuce.io. All rights reserved.