Class MaxInFlightRequestStrategy

Requests up to the max and also takes the number of messages that have been queued internally or delegated to other actors into account. Concrete subclass must implement InFlight. It will request elements in minimum batches of the defined BatchSize.

Inheritance
Object
MaxInFlightRequestStrategy
Implements
Inherited Members
Namespace: Akka.Streams.Actors
Assembly: Akka.Streams.dll
Syntax
public abstract class MaxInFlightRequestStrategy : IRequestStrategy

Constructors

| Improve this Doc View Source

MaxInFlightRequestStrategy(Int32)

TBD

Declaration
protected MaxInFlightRequestStrategy(int max)
Parameters
Type Name Description
Int32 max

TBD

Fields

| Improve this Doc View Source

Max

TBD

Declaration
public readonly int Max
Field Value
Type Description
Int32

Properties

| Improve this Doc View Source

BatchSize

Elements will be requested in minimum batches of this size. Default is 5. Subclass may override to define the batch size.

Declaration
public virtual int BatchSize { get; }
Property Value
Type Description
Int32
| Improve this Doc View Source

InFlight

Concrete subclass must implement this method to define how many messages that are currently in progress or queued.

Declaration
public abstract int InFlight { get; }
Property Value
Type Description
Int32

Methods

| Improve this Doc View Source

RequestDemand(Int32)

TBD

Declaration
public int RequestDemand(int remainingRequested)
Parameters
Type Name Description
Int32 remainingRequested

TBD
Returns
Type Description
Int32

TBD

Implements

Extension Methods