Package akka.actor.typed.internal.pubsub

Class TopicImpl<T>

java.lang.Object

akka.actor.typed.Behavior<T>

akka.actor.typed.ExtensibleBehavior<T>

akka.actor.typed.scaladsl.AbstractBehavior<TopicImpl.Command<T>>

akka.actor.typed.internal.pubsub.TopicImpl<T>

public final class TopicImpl<T>
extends AbstractBehavior<TopicImpl.Command<T>>

INTERNAL API

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	TopicImpl.Command<T>
static class	TopicImpl.GetTopicStats<T>
static class	TopicImpl.GetTopicStats$
static class	TopicImpl.MessagePublished<T>
static class	TopicImpl.MessagePublished$
static class	TopicImpl.Publish<T>
static class	TopicImpl.Publish$
static class	TopicImpl.Subscribe<T>
static class	TopicImpl.Subscribe$
static class	TopicImpl.SubscriberTerminated<T>
static class	TopicImpl.SubscriberTerminated$
static class	TopicImpl.TopicInstancesUpdated<T>
static class	TopicImpl.TopicInstancesUpdated$
static class	TopicImpl.TopicStats
static class	TopicImpl.TopicStats$
static class	TopicImpl.Unsubscribe<T>
static class	TopicImpl.Unsubscribe$

Nested classes/interfaces inherited from class akka.actor.typed.Behavior

Behavior.BehaviorDecorators<Inner>, Behavior.BehaviorDecorators$

Constructor Summary

Constructors

Constructor	Description
TopicImpl(java.lang.String topicName, ActorContext<TopicImpl.Command<T>> context, scala.reflect.ClassTag<T> classTag)

Method Summary

Modifier and Type	Method	Description
Behavior<TopicImpl.Command<T>>	onMessage(TopicImpl.Command<T> msg)	Implement this method to process an incoming message and return the next behavior.

Methods inherited from class akka.actor.typed.scaladsl.AbstractBehavior

context, onSignal, receive, receiveSignal

Methods inherited from class akka.actor.typed.Behavior

_tag, BehaviorDecorators, canonicalize, existsInStack, interpretMessage, interpretSignal, isAlive, isDeferred, isUnhandled, narrow, start, unsafeCast, validateAsInitial

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TopicImpl

public TopicImpl(java.lang.String topicName,
                 ActorContext<TopicImpl.Command<T>> context,
                 scala.reflect.ClassTag<T> classTag)

Method Detail

onMessage

public Behavior<TopicImpl.Command<T>> onMessage(TopicImpl.Command<T> msg)

Description copied from class: AbstractBehavior

Implement this method to process an incoming message and return the next behavior.

The returned behavior can in addition to normal behaviors be one of the canned special objects:

• returning stopped will terminate this Behavior
• returning this or same designates to reuse the current Behavior
• returning unhandled keeps the same Behavior and signals that the message was not yet handled

Specified by:

onMessage in class AbstractBehavior<TopicImpl.Command<T>>