akka.stream

Class ThrottleMode$

java.lang.Object

akka.stream.ThrottleMode$

public class ThrottleMode$
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static ThrottleMode$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
ThrottleMode$()

Method Summary

Modifier and Type	Method and Description
ThrottleMode.Enforcing$	enforcing() Java API: Makes throttle fail with exception when upstream is faster than throttle rate
ThrottleMode.Shaping$	shaping() Java API: Tells throttle to make pauses before emitting messages to meet throttle rate

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final ThrottleMode$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

ThrottleMode$

public ThrottleMode$()

Method Detail

shaping

public ThrottleMode.Shaping$ shaping()

Java API: Tells throttle to make pauses before emitting messages to meet throttle rate

Returns:

(undocumented)

enforcing

public ThrottleMode.Enforcing$ enforcing()

Java API: Makes throttle fail with exception when upstream is faster than throttle rate

Returns:

(undocumented)