Class DistributedPubSubMediator.Internal$.TerminateRequest$

java.lang.Object
org.apache.pekko.cluster.pubsub.DistributedPubSubMediator.Internal$.TerminateRequest$
All Implemented Interfaces:
Serializable, scala.Equals, scala.Product
Enclosing class:
DistributedPubSubMediator.Internal$

public class DistributedPubSubMediator.Internal$.TerminateRequest$ extends Object implements scala.Product, Serializable
Sent from parent to child actor to signalize that messages are being buffered. When received by child actor if no DistributedPubSubMediator.Subscribe message has been received after sending DistributedPubSubMediator.Internal$.NoMoreSubscribers message child actor will stop itself.
See Also:
  • Field Details

  • Constructor Details

    • TerminateRequest$

      public TerminateRequest$()
  • 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