Package akka.stream
Class StreamSubscriptionTimeoutTerminationMode$
- java.lang.Object
-
- akka.stream.StreamSubscriptionTimeoutTerminationMode$
-
public class StreamSubscriptionTimeoutTerminationMode$ extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description static StreamSubscriptionTimeoutTerminationMode$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description StreamSubscriptionTimeoutTerminationMode$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description StreamSubscriptionTimeoutTerminationMode
cancel()
When the timeout expires attach a Subscriber that will immediately cancel its subscription.StreamSubscriptionTimeoutTerminationMode
noop()
Do not do anything when timeout expires.StreamSubscriptionTimeoutTerminationMode
warn()
Log a warning when the timeout expires.
-
-
-
Field Detail
-
MODULE$
public static final StreamSubscriptionTimeoutTerminationMode$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
noop
public StreamSubscriptionTimeoutTerminationMode noop()
Do not do anything when timeout expires.
-
warn
public StreamSubscriptionTimeoutTerminationMode warn()
Log a warning when the timeout expires.
-
cancel
public StreamSubscriptionTimeoutTerminationMode cancel()
When the timeout expires attach a Subscriber that will immediately cancel its subscription.
-
-