Package akka.stream
Class Attributes.CancellationStrategy
- java.lang.Object
-
- akka.stream.Attributes.CancellationStrategy
-
- All Implemented Interfaces:
Attributes.Attribute
,Attributes.MandatoryAttribute
,java.io.Serializable
,scala.Equals
,scala.Product
- Enclosing class:
- Attributes
public static final class Attributes.CancellationStrategy extends java.lang.Object implements Attributes.MandatoryAttribute, scala.Product, java.io.Serializable
Cancellation strategies provide a way to configure the behavior of a stage whencancelStage
is called.It is only relevant for stream components that have more than one output and do not define a custom cancellation behavior by overriding
onDownstreamFinish
. In those cases, if the first output is cancelled, the default behavior is to callcancelStage
which shuts down the stage completely. The given strategy will allow customization of how the shutdown procedure should be done precisely.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description CancellationStrategy(akka.stream.Attributes.CancellationStrategy.Strategy strategy)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
canEqual(java.lang.Object x$1)
Attributes.CancellationStrategy
copy(akka.stream.Attributes.CancellationStrategy.Strategy strategy)
akka.stream.Attributes.CancellationStrategy.Strategy
copy$default$1()
boolean
equals(java.lang.Object x$1)
int
hashCode()
int
productArity()
java.lang.Object
productElement(int x$1)
java.lang.String
productElementName(int x$1)
scala.collection.Iterator<java.lang.Object>
productIterator()
java.lang.String
productPrefix()
akka.stream.Attributes.CancellationStrategy.Strategy
strategy()
java.lang.String
toString()
-
-
-
Method Detail
-
strategy
public akka.stream.Attributes.CancellationStrategy.Strategy strategy()
-
copy
public Attributes.CancellationStrategy copy(akka.stream.Attributes.CancellationStrategy.Strategy strategy)
-
copy$default$1
public akka.stream.Attributes.CancellationStrategy.Strategy copy$default$1()
-
productPrefix
public java.lang.String productPrefix()
- Specified by:
productPrefix
in interfacescala.Product
-
productArity
public int productArity()
- Specified by:
productArity
in interfacescala.Product
-
productElement
public java.lang.Object productElement(int x$1)
- Specified by:
productElement
in interfacescala.Product
-
productIterator
public scala.collection.Iterator<java.lang.Object> productIterator()
- Specified by:
productIterator
in interfacescala.Product
-
canEqual
public boolean canEqual(java.lang.Object x$1)
- Specified by:
canEqual
in interfacescala.Equals
-
productElementName
public java.lang.String productElementName(int x$1)
- Specified by:
productElementName
in interfacescala.Product
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
equals
public boolean equals(java.lang.Object x$1)
- Specified by:
equals
in interfacescala.Equals
- Overrides:
equals
in classjava.lang.Object
-
-