Package org.apache.pekko.stream

Class StreamSubscriptionTimeoutTerminationMode$

java.lang.Object

org.apache.pekko.stream.StreamSubscriptionTimeoutTerminationMode$

public class StreamSubscriptionTimeoutTerminationMode$
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final StreamSubscriptionTimeoutTerminationMode$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
StreamSubscriptionTimeoutTerminationMode$()

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

MODULE$

public static final StreamSubscriptionTimeoutTerminationMode$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

StreamSubscriptionTimeoutTerminationMode$

public StreamSubscriptionTimeoutTerminationMode$()

Method Details

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.