akka.stream

Class StreamSubscriptionTimeoutSettings

java.lang.Object

akka.stream.StreamSubscriptionTimeoutSettings

public final class StreamSubscriptionTimeoutSettings
extends java.lang.Object

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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(java.lang.Object other)
StreamSubscriptionTimeoutTerminationMode	mode()
scala.concurrent.duration.FiniteDuration	timeout()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamSubscriptionTimeoutSettings

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

Method Detail

create

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

Create settings from individual values (Java).

Parameters:

mode - (undocumented)

timeout - (undocumented)

Returns:

(undocumented)

apply

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

Create settings from individual values (Scala).

Parameters:

mode - (undocumented)

timeout - (undocumented)

Returns:

(undocumented)

create

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

Create settings from a Config subsection (Java).

Parameters:

config - (undocumented)

Returns:

(undocumented)

apply

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

Create settings from a Config subsection (Scala).

Parameters:

config - (undocumented)

Returns:

(undocumented)

mode

public StreamSubscriptionTimeoutTerminationMode mode()

timeout

public scala.concurrent.duration.FiniteDuration timeout()

equals

public boolean equals(java.lang.Object other)

Overrides:

equals in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object