Class Throttle<T>

INTERNAL API

Inheritance
System.Object
GraphStageWithMaterializedValue<FlowShape<T, T>, NotUsed>
GraphStage<FlowShape<T, T>>
SimpleLinearGraphStage<T>
Throttle<T>
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
Namespace: Akka.Streams.Implementation
Assembly: Akka.Streams.dll
Syntax
public class Throttle<T> : SimpleLinearGraphStage<T>, IGraphStageWithMaterializedValue<FlowShape<T, T>, NotUsed>, IGraph<FlowShape<T, T>, NotUsed>, IGraph<FlowShape<T, T>>
Type Parameters
Name Description
T

TBD

Constructors

| Improve this Doc View Source

Throttle(Int32, TimeSpan, Int32, Func<T, Int32>, ThrottleMode)

TBD

Declaration
public Throttle(int cost, TimeSpan per, int maximumBurst, Func<T, int> costCalculation, ThrottleMode mode)
Parameters
Type Name Description
System.Int32 cost

TBD
System.TimeSpan per

TBD
System.Int32 maximumBurst

TBD
System.Func<T, System.Int32> costCalculation

TBD
ThrottleMode mode

TBD

Methods

| Improve this Doc View Source

CreateLogic(Attributes)

TBD

Declaration
protected override GraphStageLogic CreateLogic(Attributes inheritedAttributes)
Parameters
Type Name Description
Attributes inheritedAttributes

TBD
Returns
Type Description
GraphStageLogic

TBD
Overrides
Akka.Streams.Stage.GraphStage<Akka.Streams.FlowShape<T, T>>.CreateLogic(Akka.Streams.Attributes)
| Improve this Doc View Source

ToString()

TBD

Declaration
public override string ToString()
Returns
Type Description
System.String

TBD
Overrides
System.Object.ToString()

Extension Methods