Package org.apache.pekko.stream

Class StreamSubscriptionTimeoutSettings

java.lang.Object

org.apache.pekko.stream.StreamSubscriptionTimeoutSettings

public final class StreamSubscriptionTimeoutSettings
extends Object

Leaked publishers and subscribers are cleaned up when they are not used within a given deadline, configured by StreamSubscriptionTimeoutSettings.

Constructor Summary

Constructors

Constructor	Description
StreamSubscriptionTimeoutSettings(StreamSubscriptionTimeoutTerminationMode mode, scala.concurrent.duration.FiniteDuration timeout)

Method Summary

Modifier and Type	Method	Description
static StreamSubscriptionTimeoutSettings	apply(com.typesafe.config.Config config)	Create settings from a Config subsection (Scala).
static StreamSubscriptionTimeoutSettings	apply(StreamSubscriptionTimeoutTerminationMode mode, scala.concurrent.duration.FiniteDuration timeout)	Create settings from individual values (Scala).
static StreamSubscriptionTimeoutSettings	create(com.typesafe.config.Config config)	Create settings from a Config subsection (Java).
static StreamSubscriptionTimeoutSettings	create(StreamSubscriptionTimeoutTerminationMode mode, scala.concurrent.duration.FiniteDuration timeout)	Create settings from individual values (Java).
boolean	equals(Object other)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

StreamSubscriptionTimeoutSettings

public StreamSubscriptionTimeoutSettings(StreamSubscriptionTimeoutTerminationMode mode,
 scala.concurrent.duration.FiniteDuration timeout)

Method Details

create

public static StreamSubscriptionTimeoutSettings create(StreamSubscriptionTimeoutTerminationMode mode,
 scala.concurrent.duration.FiniteDuration timeout)

Create settings from individual values (Java).

apply

public static StreamSubscriptionTimeoutSettings apply(StreamSubscriptionTimeoutTerminationMode mode,
 scala.concurrent.duration.FiniteDuration timeout)

Create settings from individual values (Scala).

create

public static StreamSubscriptionTimeoutSettings create(com.typesafe.config.Config config)

Create settings from a Config subsection (Java).

apply

public static StreamSubscriptionTimeoutSettings apply(com.typesafe.config.Config config)

Create settings from a Config subsection (Scala).

equals

public boolean equals(Object other)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object