DistributedPubSubMediator.Internal$.NewSubscriberArrived

java.lang.Object

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

Enclosing class:: DistributedPubSubMediator.Internal$

public class DistributedPubSubMediator.Internal$.NewSubscriberArrived extends Object

Sent from child to parent actor as response to DistributedPubSubMediator.Internal$.TerminateRequest in case DistributedPubSubMediator.Subscribe message arrived after sending DistributedPubSubMediator.Internal$.NoMoreSubscribers but before receiving DistributedPubSubMediator.Internal$.TerminateRequest.

When received by the parent buffered messages will be forwarded to child actor for processing.

Constructor Summary

Constructors

Constructor

Description

NewSubscriberArrived()
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
- NewSubscriberArrived
  
  public NewSubscriberArrived()
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()