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)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - MaxInFlightRequestStrategy
```
public MaxInFlightRequestStrategy(int max)
```
- 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 interface RequestStrategy