public class Throttle<T> extends GraphStages.SimpleLinearGraphStage<T>
Constructor and Description |
---|
Throttle(int cost,
scala.concurrent.duration.FiniteDuration per,
int maximumBurst,
scala.Function1<T,java.lang.Object> costCalculation,
ThrottleMode mode) |
Modifier and Type | Method and Description |
---|---|
int |
cost() |
scala.Function1<T,java.lang.Object> |
costCalculation() |
GraphStageLogic |
createLogic(Attributes inheritedAttributes) |
int |
maximumBurst() |
ThrottleMode |
mode() |
scala.concurrent.duration.FiniteDuration |
per() |
java.lang.String |
toString() |
in, out, shape
createLogicAndMaterializedValue
initialAttributes, module, withAttributes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addAttributes, async, named
public Throttle(int cost, scala.concurrent.duration.FiniteDuration per, int maximumBurst, scala.Function1<T,java.lang.Object> costCalculation, ThrottleMode mode)
public int cost()
public scala.concurrent.duration.FiniteDuration per()
public int maximumBurst()
public scala.Function1<T,java.lang.Object> costCalculation()
public ThrottleMode mode()
public GraphStageLogic createLogic(Attributes inheritedAttributes)
createLogic
in class GraphStage<FlowShape<T,T>>
public java.lang.String toString()
toString
in class java.lang.Object