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 SummaryConstructors Constructor Description InputBuffer(int initial, int max)
 - 
Method SummaryAll 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- 
initialpublic int initial() 
 - 
maxpublic int max() 
 - 
copypublic Attributes.InputBuffer copy(int initial, int max) 
 - 
copy$default$1public int copy$default$1() 
 - 
copy$default$2public int copy$default$2() 
 - 
productPrefixpublic java.lang.String productPrefix() - Specified by:
- productPrefixin interface- scala.Product
 
 - 
productAritypublic int productArity() - Specified by:
- productArityin interface- scala.Product
 
 - 
productElementpublic java.lang.Object productElement(int x$1) - Specified by:
- productElementin interface- scala.Product
 
 - 
productIteratorpublic scala.collection.Iterator<java.lang.Object> productIterator() - Specified by:
- productIteratorin interface- scala.Product
 
 - 
canEqualpublic boolean canEqual(java.lang.Object x$1) - Specified by:
- canEqualin interface- scala.Equals
 
 - 
productElementNamepublic java.lang.String productElementName(int x$1) - Specified by:
- productElementNamein interface- scala.Product
 
 - 
hashCodepublic int hashCode() - Overrides:
- hashCodein class- java.lang.Object
 
 - 
toStringpublic java.lang.String toString() - Overrides:
- toStringin class- java.lang.Object
 
 - 
equalspublic boolean equals(java.lang.Object x$1) - Specified by:
- equalsin interface- scala.Equals
- Overrides:
- equalsin class- java.lang.Object
 
 
- 
 
-