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

| Edit this page View Source

MaxInFlightRequestStrategy(int)

TBD

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

TBD

Fields

| Edit this page View Source

Max

TBD

Declaration
public readonly int Max
Field Value
Type Description
int

Properties

| Edit this page 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
int
| Edit this page 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
int

Methods

| Edit this page View Source

RequestDemand(int)

TBD

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

TBD
Returns
Type Description
int

TBD

Implements

Extension Methods