akka.stream

Class StreamSubscriptionTimeoutTerminationMode

java.lang.Object

akka.stream.StreamSubscriptionTimeoutTerminationMode

Direct Known Subclasses:

StreamSubscriptionTimeoutTerminationMode.CancelTermination$, StreamSubscriptionTimeoutTerminationMode.NoopTermination$, StreamSubscriptionTimeoutTerminationMode.WarnTermination$

public abstract class StreamSubscriptionTimeoutTerminationMode
extends java.lang.Object

This mode describes what shall happen when the subscription timeout expires for substream Publishers created by operations like prefixAndTail.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StreamSubscriptionTimeoutTerminationMode.CancelTermination$
static class	StreamSubscriptionTimeoutTerminationMode.NoopTermination$
static class	StreamSubscriptionTimeoutTerminationMode.WarnTermination$

Constructor Summary

Constructors

Constructor and Description
StreamSubscriptionTimeoutTerminationMode()

Method Summary

Modifier and Type	Method and Description
static StreamSubscriptionTimeoutTerminationMode	cancel() When the timeout expires attach a Subscriber that will immediately cancel its subscription.
static StreamSubscriptionTimeoutTerminationMode	noop() Do not do anything when timeout expires.
static 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

Constructor Detail

StreamSubscriptionTimeoutTerminationMode

public StreamSubscriptionTimeoutTerminationMode()

Method Detail

noop

public static StreamSubscriptionTimeoutTerminationMode noop()

Do not do anything when timeout expires.

Returns:

(undocumented)

warn

public static StreamSubscriptionTimeoutTerminationMode warn()

Log a warning when the timeout expires.

Returns:

(undocumented)

cancel

public static StreamSubscriptionTimeoutTerminationMode cancel()

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

Returns:

(undocumented)