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 booleancanEqual(java.lang.Object x$1)Attributes.InputBuffercopy(int initial, int max)intcopy$default$1()intcopy$default$2()booleanequals(java.lang.Object x$1)inthashCode()intinitial()intmax()intproductArity()java.lang.ObjectproductElement(int x$1)java.lang.StringproductElementName(int x$1)scala.collection.Iterator<java.lang.Object>productIterator()java.lang.StringproductPrefix()java.lang.StringtoString()
-
-
-
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:
productPrefixin interfacescala.Product
-
productArity
public int productArity()
- Specified by:
productArityin interfacescala.Product
-
productElement
public java.lang.Object productElement(int x$1)
- Specified by:
productElementin interfacescala.Product
-
productIterator
public scala.collection.Iterator<java.lang.Object> productIterator()
- Specified by:
productIteratorin interfacescala.Product
-
canEqual
public boolean canEqual(java.lang.Object x$1)
- Specified by:
canEqualin interfacescala.Equals
-
productElementName
public java.lang.String productElementName(int x$1)
- Specified by:
productElementNamein interfacescala.Product
-
hashCode
public int hashCode()
- Overrides:
hashCodein classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toStringin classjava.lang.Object
-
equals
public boolean equals(java.lang.Object x$1)
- Specified by:
equalsin interfacescala.Equals- Overrides:
equalsin classjava.lang.Object
-
-