akka.typed.internal

Interface DeathWatch<T>

All Known Implementing Classes:

ActorCell

public interface DeathWatch<T>

Method Summary

Modifier and Type	Method and Description
void	addressTerminated(Address address)
void	addWatcher(ActorRefImpl<scala.runtime.Nothing$> watchee, ActorRefImpl<scala.runtime.Nothing$> watcher)
Behavior<T>	behavior()
scala.collection.immutable.Map<java.lang.String,ActorRefImpl<scala.runtime.Nothing$>>	childrenMap()
java.lang.Class<?>	clazz(java.lang.Object obj)
ActorContext<T>	ctx()
void	finishTerminate()
boolean	isTerminating()
<U> U	maintainAddressTerminatedSubscription(ActorRefImpl<scala.runtime.Nothing$> change, scala.Function0<U> block) Starts subscription to AddressTerminated if not already subscribing and the block adds a non-local ref to watching or watchedBy.
boolean	maySend()
void	next(Behavior<T> b, java.lang.Object msg)
ActorRefImpl<scala.runtime.Nothing$>	parent()
void	publish(Logging.LogEvent e)
void	removeChild(ActorRefImpl<scala.runtime.Nothing$> actor)
void	remWatcher(ActorRefImpl<scala.runtime.Nothing$> watchee, ActorRefImpl<scala.runtime.Nothing$> watcher)
ActorRefImpl<T>	self()
void	subscribeAddressTerminated()
ActorSystem<scala.runtime.Nothing$>	system()
void	tellWatchersWeDied()
scala.collection.immutable.Map<java.lang.String,ActorRefImpl<scala.runtime.Nothing$>>	terminatingMap()
void	unsubscribeAddressTerminated()
<U> ActorRef<U>	unwatch(ActorRef<U> _a)
void	unwatchWatchedActors()
<U> ActorRef<U>	watch(ActorRef<U> _a)
boolean	watchedActorTerminated(ActorRefImpl<scala.runtime.Nothing$> actor, java.lang.Throwable failure) When this actor is watching the subject of Terminated message it will be propagated to user's receive.

Method Detail

system

ActorSystem<scala.runtime.Nothing$> system()

self

ActorRefImpl<T> self()

parent

ActorRefImpl<scala.runtime.Nothing$> parent()

behavior

Behavior<T> behavior()

next

void next(Behavior<T> b,
          java.lang.Object msg)

childrenMap

scala.collection.immutable.Map<java.lang.String,ActorRefImpl<scala.runtime.Nothing$>> childrenMap()

terminatingMap

scala.collection.immutable.Map<java.lang.String,ActorRefImpl<scala.runtime.Nothing$>> terminatingMap()

isTerminating

boolean isTerminating()

ctx

ActorContext<T> ctx()

maySend

boolean maySend()

publish

void publish(Logging.LogEvent e)

clazz

java.lang.Class<?> clazz(java.lang.Object obj)

removeChild

void removeChild(ActorRefImpl<scala.runtime.Nothing$> actor)

finishTerminate

void finishTerminate()

watch

<U> ActorRef<U> watch(ActorRef<U> _a)

unwatch

<U> ActorRef<U> unwatch(ActorRef<U> _a)

watchedActorTerminated

boolean watchedActorTerminated(ActorRefImpl<scala.runtime.Nothing$> actor,
                               java.lang.Throwable failure)

When this actor is watching the subject of Terminated message it will be propagated to user's receive.

Parameters:

actor - (undocumented)

failure - (undocumented)

Returns:

(undocumented)

tellWatchersWeDied

void tellWatchersWeDied()

unwatchWatchedActors

void unwatchWatchedActors()

addWatcher

void addWatcher(ActorRefImpl<scala.runtime.Nothing$> watchee,
                ActorRefImpl<scala.runtime.Nothing$> watcher)

remWatcher

void remWatcher(ActorRefImpl<scala.runtime.Nothing$> watchee,
                ActorRefImpl<scala.runtime.Nothing$> watcher)

addressTerminated

void addressTerminated(Address address)

maintainAddressTerminatedSubscription

<U> U maintainAddressTerminatedSubscription(ActorRefImpl<scala.runtime.Nothing$> change,
                                            scala.Function0<U> block)

Starts subscription to AddressTerminated if not already subscribing and the block adds a non-local ref to watching or watchedBy. Ends subscription to AddressTerminated if subscribing and the block removes the last non-local ref from watching and watchedBy.

Parameters:

change - (undocumented)

block - (undocumented)

Returns:

(undocumented)

unsubscribeAddressTerminated

void unsubscribeAddressTerminated()

subscribeAddressTerminated

void subscribeAddressTerminated()