Package akka.stream.actor
Class MaxInFlightRequestStrategy
- java.lang.Object
-
- akka.stream.actor.MaxInFlightRequestStrategy
-
- All Implemented Interfaces:
RequestStrategy
public abstract class MaxInFlightRequestStrategy extends java.lang.Object implements RequestStrategy
Concrete subclass must implement this method to define how many messages that are currently in progress or queued.
-
-
Constructor Summary
Constructors Constructor Description MaxInFlightRequestStrategy(int max)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description int
batchSize()
Elements will be requested in minimum batches of this size.abstract int
inFlightInternally()
int
requestDemand(int remainingRequested)
-
-
-
Method Detail
-
batchSize
public int batchSize()
Elements will be requested in minimum batches of this size. Default is 5. Subclass may override to define the batch size.- Returns:
- (undocumented)
-
inFlightInternally
public abstract int inFlightInternally()
-
requestDemand
public int requestDemand(int remainingRequested)
- Specified by:
requestDemand
in interfaceRequestStrategy
-
-