Package org.apache.pekko.stream

Class StreamSubscriptionTimeoutTerminationMode

java.lang.Object

org.apache.pekko.stream.StreamSubscriptionTimeoutTerminationMode

Direct Known Subclasses:

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

public abstract class StreamSubscriptionTimeoutTerminationMode
extends 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	Description
static class	StreamSubscriptionTimeoutTerminationMode.CancelTermination$
static class	StreamSubscriptionTimeoutTerminationMode.NoopTermination$
static class	StreamSubscriptionTimeoutTerminationMode.WarnTermination$

Constructor Summary

Constructors

Constructor	Description
StreamSubscriptionTimeoutTerminationMode()

Method Summary

Modifier and Type	Method	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 Details

StreamSubscriptionTimeoutTerminationMode

public StreamSubscriptionTimeoutTerminationMode()

Method Details

noop

public static StreamSubscriptionTimeoutTerminationMode noop()

Do not do anything when timeout expires.

warn

public static StreamSubscriptionTimeoutTerminationMode warn()

Log a warning when the timeout expires.

cancel

public static StreamSubscriptionTimeoutTerminationMode cancel()

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