DistributedPubSubMediator.Internal$.TerminateRequest

java.lang.Object

org.apache.pekko.cluster.pubsub.DistributedPubSubMediator.Internal$.TerminateRequest

Enclosing class:: DistributedPubSubMediator.Internal$

public class DistributedPubSubMediator.Internal$.TerminateRequest extends Object

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.

Constructor Summary

Constructors

Constructor

Description

TerminateRequest()
Method Summary

Modifier and Type

Method

Description

static boolean

canEqual(Object x$1)

abstract static boolean

equals(Object that)

static int

hashCode()

static int

productArity()

static Object

productElement(int x$1)

static String

productElementName(int n)

static scala.collection.Iterator<String>

productElementNames()

static scala.collection.Iterator<Object>

productIterator()

static String

productPrefix()

static String

toString()

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- TerminateRequest
  
  public TerminateRequest()
Method Details
- productPrefix
  
  public static String productPrefix()
- productArity
  
  public static int productArity()
- productElement
  
  public static Object productElement(int x$1)
- productIterator
  
  public static scala.collection.Iterator<Object> productIterator()
- canEqual
  
  public static boolean canEqual(Object x$1)
- hashCode
  
  public static int hashCode()
- toString
  
  public static String toString()
- equals
  
  public abstract static boolean equals(Object that)
- productElementName
  
  public static String productElementName(int n)
- productElementNames
  
  public static scala.collection.Iterator<String> productElementNames()