akka.stream

Class StreamSubscriptionTimeoutTerminationMode$

java.lang.Object

akka.stream.StreamSubscriptionTimeoutTerminationMode$

public class StreamSubscriptionTimeoutTerminationMode$
extends java.lang.Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
StreamSubscriptionTimeoutTerminationMode$()

Method Summary

Modifier and Type	Method and Description
StreamSubscriptionTimeoutTerminationMode	cancel() When the timeout expires attach a Subscriber that will immediately cancel its subscription.
StreamSubscriptionTimeoutTerminationMode	noop() Do not do anything when timeout expires.
StreamSubscriptionTimeoutTerminationMode	warn() Log a warning when the timeout expires.

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final StreamSubscriptionTimeoutTerminationMode$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

StreamSubscriptionTimeoutTerminationMode$

public StreamSubscriptionTimeoutTerminationMode$()

Method Detail

noop

public StreamSubscriptionTimeoutTerminationMode noop()

Do not do anything when timeout expires.

Returns:

(undocumented)

warn

public StreamSubscriptionTimeoutTerminationMode warn()

Log a warning when the timeout expires.

Returns:

(undocumented)

cancel

public StreamSubscriptionTimeoutTerminationMode cancel()

When the timeout expires attach a Subscriber that will immediately cancel its subscription.

Returns:

(undocumented)