ThrottleMode

java.lang.Object

org.apache.pekko.stream.ThrottleMode

Direct Known Subclasses:: ThrottleMode.Enforcing$, ThrottleMode.Shaping$

public abstract class ThrottleMode extends Object

Represents a mode that decides how to deal exceed rate for Throttle operator

Nested Class Summary

Nested Classes

Modifier and Type

Class

Description

static class

ThrottleMode.Enforcing$

Makes throttle fail with exception when upstream is faster than throttle rate

static class

ThrottleMode.Shaping$

Tells throttle to make pauses before emitting messages to meet throttle rate
Constructor Summary

Constructors

Constructor

Description

ThrottleMode()
Method Summary

Modifier and Type

Method

Description

static ThrottleMode.Enforcing$

enforcing()

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

static 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

Constructor Details
- ThrottleMode
  
  public ThrottleMode()
Method Details
- shaping
  
  public static ThrottleMode.Shaping$ shaping()
  
  Java API: Tells throttle to make pauses before emitting messages to meet throttle rate
- enforcing
  
  public static ThrottleMode.Enforcing$ enforcing()
  
  Java API: Makes throttle fail with exception when upstream is faster than throttle rate