RequestStrategy

All Known Implementing Classes:

MaxInFlightRequestStrategy, OneByOneRequestStrategy$, WatermarkRequestStrategy, ZeroRequestStrategy$
```
public interface RequestStrategy
```
Invoked by the ActorSubscriber after each incoming message to determine how many more elements to request from the stream.
param: remainingRequested current remaining number of elements that have been requested from upstream but not received yet

- Method Summary
  
  All Methods Instance Methods Abstract Methods
  Modifier and Type Method Description
  
  int requestDemand(int remainingRequested)

Method Detail

requestDemand

int requestDemand(int remainingRequested)