Package 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 likeprefixAndTail
.
-
-
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
All Methods Static Methods Concrete Methods 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.
-
-
-
Method Detail
-
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.
-
-