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 java.lang.ObjectThis 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 classStreamSubscriptionTimeoutTerminationMode.CancelTermination$static classStreamSubscriptionTimeoutTerminationMode.NoopTermination$static classStreamSubscriptionTimeoutTerminationMode.WarnTermination$
-
Constructor Summary
Constructors Constructor Description StreamSubscriptionTimeoutTerminationMode()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static StreamSubscriptionTimeoutTerminationModecancel()When the timeout expires attach a Subscriber that will immediately cancel its subscription.static StreamSubscriptionTimeoutTerminationModenoop()Do not do anything when timeout expires.static StreamSubscriptionTimeoutTerminationModewarn()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.
-
-