Package org.apache.pekko.io
Class Tcp.ResumeAccepting
java.lang.Object
org.apache.pekko.io.Tcp.ResumeAccepting
- All Implemented Interfaces:
Serializable,NoSerializationVerificationNeeded,org.apache.pekko.io.SelectionHandler.HasFailureMessage,Tcp.Command,Tcp.Message,scala.Equals,scala.Product
- Enclosing class:
- Tcp
public static final class Tcp.ResumeAccepting
extends Object
implements Tcp.Command, scala.Product, Serializable
This message enables the accepting of the next connection if read throttling is enabled
for connection actors.
param: batchSize The number of connections to accept before waiting for the next resume command
- See Also:
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionintbooleancopy(int batchSize) intbooleaninthashCode()intproductElement(int x$1) productElementName(int x$1) scala.collection.Iterator<Object>toString()Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, waitMethods inherited from interface scala.Product
productElementNamesMethods inherited from interface org.apache.pekko.io.Tcp.Command
failureMessage
-
Constructor Details
-
ResumeAccepting
public ResumeAccepting(int batchSize)
-
-
Method Details
-
batchSize
public int batchSize() -
copy
-
copy$default$1
public int copy$default$1() -
productPrefix
- Specified by:
productPrefixin interfacescala.Product
-
productArity
public int productArity()- Specified by:
productArityin interfacescala.Product
-
productElement
- Specified by:
productElementin interfacescala.Product
-
productIterator
- Specified by:
productIteratorin interfacescala.Product
-
canEqual
- Specified by:
canEqualin interfacescala.Equals
-
productElementName
- Specified by:
productElementNamein interfacescala.Product
-
hashCode
public int hashCode() -
toString
-
equals
-