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.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. 
 - 
 
 -