Package org.apache.pekko.io

Class Tcp.ResumeWriting$

java.lang.Object
org.apache.pekko.io.Tcp.ResumeWriting$
All Implemented Interfaces:
Serializable, NoSerializationVerificationNeeded, org.apache.pekko.io.SelectionHandler.HasFailureMessage, Tcp.Command, Tcp.Message, scala.Equals, scala.Product
Enclosing class:
Tcp
public static class Tcp.ResumeWriting$ extends Object implements Tcp.Command, scala.Product, Serializable
When useResumeWriting is in effect as was indicated in the Tcp.Register message then this command needs to be sent to the connection actor in order to re-enable writing after a Tcp.CommandFailed event. All Tcp.WriteCommand processed by the connection actor between the first Tcp.CommandFailed and subsequent reception of this message will also be rejected with Tcp.CommandFailed.
See Also:

  • Field Details

    • MODULE$

      public static final Tcp.ResumeWriting$ MODULE$
      Static reference to the singleton instance of this Scala object.

  • Constructor Details

    • ResumeWriting$

      public ResumeWriting$()

  • Method Details

    • productPrefix

      public String productPrefix()
      Specified by:
      productPrefix in interface scala.Product

    • productArity

      public int productArity()
      Specified by:
      productArity in interface scala.Product

    • productElement

      public Object productElement(int x$1)
      Specified by:
      productElement in interface scala.Product

    • productIterator

      public scala.collection.Iterator<Object> productIterator()
      Specified by:
      productIterator in interface scala.Product

    • canEqual

      public boolean canEqual(Object x$1)
      Specified by:
      canEqual in interface scala.Equals

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object