Package org.apache.pekko.stream
Class StreamSubscriptionTimeoutTerminationMode
java.lang.Object
org.apache.pekko.stream.StreamSubscriptionTimeoutTerminationMode
- Direct Known Subclasses:
StreamSubscriptionTimeoutTerminationMode.CancelTermination$,StreamSubscriptionTimeoutTerminationMode.NoopTermination$,StreamSubscriptionTimeoutTerminationMode.WarnTermination$
This mode describes what shall happen when the subscription timeout expires for
substream Publishers created by operations like
prefixAndTail.-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic classstatic classstatic class -
Constructor Summary
Constructors -
Method Summary
-
Constructor Details
-
StreamSubscriptionTimeoutTerminationMode
public StreamSubscriptionTimeoutTerminationMode()
-
-
Method Details
-
noop
Do not do anything when timeout expires. -
warn
Log a warning when the timeout expires. -
cancel
When the timeout expires attach a Subscriber that will immediately cancel its subscription.
-