Package akka.stream.impl

Class Throttle<T>

java.lang.Object

akka.stream.stage.GraphStageWithMaterializedValue<S,NotUsed>

akka.stream.stage.GraphStage<FlowShape<T,T>>

akka.stream.impl.fusing.GraphStages.SimpleLinearGraphStage<T>

akka.stream.impl.Throttle<T>

All Implemented Interfaces:

Graph<FlowShape<T,T>,NotUsed>

public class Throttle<T>
extends GraphStages.SimpleLinearGraphStage<T>

INTERNAL API

Constructor Summary

Constructors

Constructor	Description
Throttle(int cost, scala.concurrent.duration.FiniteDuration per, int maximumBurst, scala.Function1<T,java.lang.Object> costCalculation, ThrottleMode mode)

Method Summary

Modifier and Type	Method	Description
static int	AutomaticMaximumBurst()
int	cost()
scala.Function1<T,java.lang.Object>	costCalculation()
GraphStageLogic	createLogic(Attributes inheritedAttributes)
long	effectiveMaximumBurst()
int	maximumBurst()
ThrottleMode	mode()
scala.concurrent.duration.FiniteDuration	per()
java.lang.String	toString()

Methods inherited from class akka.stream.impl.fusing.GraphStages.SimpleLinearGraphStage

in, out, shape

Methods inherited from class akka.stream.stage.GraphStage

createLogicAndMaterializedValue

Methods inherited from class akka.stream.stage.GraphStageWithMaterializedValue

createLogicAndMaterializedValue, initialAttributes, traversalBuilder, withAttributes

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface akka.stream.Graph

addAttributes, async, async, async, named

Constructor Detail

Throttle

public Throttle(int cost,
                scala.concurrent.duration.FiniteDuration per,
                int maximumBurst,
                scala.Function1<T,java.lang.Object> costCalculation,
                ThrottleMode mode)

Method Detail

AutomaticMaximumBurst

public static final int AutomaticMaximumBurst()

cost

public int cost()

per

public scala.concurrent.duration.FiniteDuration per()

maximumBurst

public int maximumBurst()

costCalculation

public scala.Function1<T,java.lang.Object> costCalculation()

mode

public ThrottleMode mode()

effectiveMaximumBurst

public long effectiveMaximumBurst()

createLogic

public GraphStageLogic createLogic(Attributes inheritedAttributes)

Specified by:

createLogic in class GraphStage<FlowShape<T,T>>

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object