Package org.apache.pekko.stream
Class Attributes.InputBuffer
- java.lang.Object
-
- org.apache.pekko.stream.Attributes.InputBuffer
-
- All Implemented Interfaces:
java.io.Serializable
,Attributes.Attribute
,Attributes.MandatoryAttribute
,scala.Equals
,scala.Product
- Enclosing class:
- Attributes
public static final class Attributes.InputBuffer extends java.lang.Object implements Attributes.MandatoryAttribute, scala.Product, java.io.Serializable
Each asynchronous piece of a materialized stream topology is executed by one Actor that manages an input buffer for all inlets of its shape. This attribute configures the initial and maximal input buffer in number of elements for each inlet.Use factory method
Attributes.inputBuffer(int, int)
to create instances.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description InputBuffer(int initial, int max)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
canEqual(java.lang.Object x$1)
Attributes.InputBuffer
copy(int initial, int max)
int
copy$default$1()
int
copy$default$2()
boolean
equals(java.lang.Object x$1)
int
hashCode()
int
initial()
int
max()
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()
java.lang.String
toString()
-
-
-
Method Detail
-
initial
public int initial()
-
max
public int max()
-
copy
public Attributes.InputBuffer copy(int initial, int max)
-
copy$default$1
public int copy$default$1()
-
copy$default$2
public int copy$default$2()
-
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
-
-