Package io.lettuce.core.protocol
Interface DemandAware
-
public interface DemandAware
Interface for demand-aware components.A demand-aware component is aware of its demand for data that is read from the
DemandAware.Source
and possibly awaits processing. ADemandAware.Sink
with demand is ready to process data. ADemandAware.Sink
without demand signals that it's ability to keep up with the incoming data is no longer given and it wishes to receive no more data. Submitting more data could cause overload and exhaust buffer space.- Since:
- 5.0
- Author:
- Mark Paluch
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static interface
DemandAware.Sink
A demand-awareDemandAware.Sink
that accepts data.static interface
DemandAware.Source
ADemandAware.Source
provides data to aDemandAware
and can be notified to produce more input for the command.
-