public final class Attributes
extends java.lang.Object
implements scala.Product, scala.Serializable
Flow
/ Flow
or GraphDSL
/ GraphDSL
materialization.
Note that more attributes for the ActorMaterializer
are defined in ActorAttributes
.
Modifier and Type | Class and Description |
---|---|
static class |
Attributes.AsyncBoundary$ |
static interface |
Attributes.Attribute |
static class |
Attributes.InputBuffer |
static class |
Attributes.InputBuffer$ |
static class |
Attributes.LogLevels |
static class |
Attributes.LogLevels$ |
static class |
Attributes.Name |
static class |
Attributes.Name$ |
Constructor and Description |
---|
Attributes(scala.collection.immutable.List<Attributes.Attribute> attributeList) |
Modifier and Type | Method and Description |
---|---|
Attributes |
and(Attributes.Attribute other)
Adds given attribute to the end of these attributes.
|
Attributes |
and(Attributes other)
Adds given attributes to the end of these attributes.
|
static Attributes |
apply(Attributes.Attribute attribute)
INTERNAL API
|
static Attributes |
asyncBoundary() |
scala.collection.immutable.List<Attributes.Attribute> |
attributeList() |
abstract static boolean |
canEqual(java.lang.Object that) |
boolean |
contains(Attributes.Attribute attr)
Test whether the given attribute is contained within this attributes list.
|
static Attributes |
createLogLevels(Logging.LogLevel onElement,
Logging.LogLevel onFinish,
Logging.LogLevel onFailure)
Java API
|
abstract static boolean |
equals(java.lang.Object that) |
static java.lang.String |
extractName(StreamLayout.Module mod,
java.lang.String default_)
Compute a name by concatenating all Name attributes that the given module
has, returning the given default value if none are found.
|
<T extends Attributes.Attribute> |
filtered(scala.reflect.ClassTag<T> evidence$1)
Scala API: get all attributes of a given type (or subtypes thereof).
|
<T extends Attributes.Attribute> |
get(scala.reflect.ClassTag<T> evidence$4)
Scala API: Get the last (most specific) attribute of a given type parameter T
Class or subclass thereof. |
<T extends Attributes.Attribute> |
get(T default_,
scala.reflect.ClassTag<T> evidence$2)
Scala API: Get the last (most specific) attribute of a given type parameter T
Class or subclass thereof. |
<T extends Attributes.Attribute> |
getAttribute(java.lang.Class<T> c)
Java API: Get the last (most specific) attribute of a given
Class or subclass thereof. |
<T extends Attributes.Attribute> |
getAttribute(java.lang.Class<T> c,
T default_)
Java API: Get the last (most specific) attribute of a given
Class or subclass thereof. |
java.util.List<Attributes.Attribute> |
getAttributeList()
Java API
|
<T extends Attributes.Attribute> |
getAttributeList(java.lang.Class<T> c)
Java API: Get all attributes of a given
Class or
subclass thereof. |
<T extends Attributes.Attribute> |
getFirst(scala.reflect.ClassTag<T> evidence$5)
Scala API: Get the first (least specific) attribute of a given type parameter T
Class or subclass thereof. |
<T extends Attributes.Attribute> |
getFirst(T default_,
scala.reflect.ClassTag<T> evidence$3)
Scala API: Get the first (least specific) attribute of a given type parameter T
Class or subclass thereof. |
<T extends Attributes.Attribute> |
getFirstAttribute(java.lang.Class<T> c)
Java API: Get the first (least specific) attribute of a given
Class or subclass thereof. |
<T extends Attributes.Attribute> |
getFirstAttribute(java.lang.Class<T> c,
T default_)
Java API: Get the first (least specific) attribute of a given
Class or subclass thereof. |
static Attributes |
inputBuffer(int initial,
int max)
Specifies the initial and maximum size of the input buffer.
|
static Attributes |
logLevels(Logging.LogLevel onElement,
Logging.LogLevel onFinish,
Logging.LogLevel onFailure)
Configures
log() stage log-levels to be used when logging. |
static Attributes |
name(java.lang.String name)
Specifies the name of the operation.
|
scala.Option<java.lang.String> |
nameLifted()
Extracts Name attributes and concatenates them.
|
java.lang.String |
nameOrDefault(java.lang.String default_)
INTERNAL API
|
static Attributes |
none()
INTERNAL API
|
abstract static int |
productArity() |
abstract static java.lang.Object |
productElement(int n) |
static scala.collection.Iterator<java.lang.Object> |
productIterator() |
static java.lang.String |
productPrefix() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public Attributes(scala.collection.immutable.List<Attributes.Attribute> attributeList)
public static Attributes apply(Attributes.Attribute attribute)
attribute
- (undocumented)public static Attributes none()
public static Attributes asyncBoundary()
public static Attributes name(java.lang.String name)
none()
is returned.name
- (undocumented)public static Attributes inputBuffer(int initial, int max)
initial
- (undocumented)max
- (undocumented)public static Attributes createLogLevels(Logging.LogLevel onElement, Logging.LogLevel onFinish, Logging.LogLevel onFailure)
Configures log()
stage log-levels to be used when logging.
Logging a certain operation can be completely disabled by using LogLevels.Off
.
Passing in null as any of the arguments sets the level to its default value, which is:
Debug
for onElement
and onFinish
, and Error
for onFailure
.
onElement
- (undocumented)onFinish
- (undocumented)onFailure
- (undocumented)public static Attributes logLevels(Logging.LogLevel onElement, Logging.LogLevel onFinish, Logging.LogLevel onFailure)
log()
stage log-levels to be used when logging.
Logging a certain operation can be completely disabled by using LogLevels.Off
.
See Attributes.createLogLevels
for Java API
onElement
- (undocumented)onFinish
- (undocumented)onFailure
- (undocumented)public static java.lang.String extractName(StreamLayout.Module mod, java.lang.String default_)
mod
- (undocumented)default_
- (undocumented)public abstract static boolean canEqual(java.lang.Object that)
public abstract static boolean equals(java.lang.Object that)
public abstract static java.lang.Object productElement(int n)
public abstract static int productArity()
public static scala.collection.Iterator<java.lang.Object> productIterator()
public static java.lang.String productPrefix()
public scala.collection.immutable.List<Attributes.Attribute> attributeList()
public java.util.List<Attributes.Attribute> getAttributeList()
public <T extends Attributes.Attribute> java.util.List<T> getAttributeList(java.lang.Class<T> c)
Class
or
subclass thereof.c
- (undocumented)public <T extends Attributes.Attribute> T getAttribute(java.lang.Class<T> c, T default_)
Class
or subclass thereof.
If no such attribute exists the default
value is returned.c
- (undocumented)default_
- (undocumented)public <T extends Attributes.Attribute> T getFirstAttribute(java.lang.Class<T> c, T default_)
Class
or subclass thereof.
If no such attribute exists the default
value is returned.c
- (undocumented)default_
- (undocumented)public <T extends Attributes.Attribute> java.util.Optional<T> getAttribute(java.lang.Class<T> c)
Class
or subclass thereof.c
- (undocumented)public <T extends Attributes.Attribute> java.util.Optional<T> getFirstAttribute(java.lang.Class<T> c)
Class
or subclass thereof.c
- (undocumented)public <T extends Attributes.Attribute> scala.collection.immutable.List<T> filtered(scala.reflect.ClassTag<T> evidence$1)
evidence$1
- (undocumented)public <T extends Attributes.Attribute> T get(T default_, scala.reflect.ClassTag<T> evidence$2)
Class
or subclass thereof.
If no such attribute exists the default
value is returned.default_
- (undocumented)evidence$2
- (undocumented)public <T extends Attributes.Attribute> T getFirst(T default_, scala.reflect.ClassTag<T> evidence$3)
Class
or subclass thereof.
If no such attribute exists the default
value is returned.default_
- (undocumented)evidence$3
- (undocumented)public <T extends Attributes.Attribute> scala.Option<T> get(scala.reflect.ClassTag<T> evidence$4)
Class
or subclass thereof.evidence$4
- (undocumented)public <T extends Attributes.Attribute> scala.Option<T> getFirst(scala.reflect.ClassTag<T> evidence$5)
Class
or subclass thereof.evidence$5
- (undocumented)public boolean contains(Attributes.Attribute attr)
attr
- (undocumented)public Attributes and(Attributes other)
other
- (undocumented)public Attributes and(Attributes.Attribute other)
other
- (undocumented)public scala.Option<java.lang.String> nameLifted()
public java.lang.String nameOrDefault(java.lang.String default_)
default_
- (undocumented)