public interface DeathWatch<T>
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. |
ActorSystem<scala.runtime.Nothing$> system()
ActorRefImpl<T> self()
ActorRefImpl<scala.runtime.Nothing$> parent()
scala.collection.immutable.Map<java.lang.String,ActorRefImpl<scala.runtime.Nothing$>> childrenMap()
scala.collection.immutable.Map<java.lang.String,ActorRefImpl<scala.runtime.Nothing$>> terminatingMap()
boolean isTerminating()
ActorContext<T> ctx()
boolean maySend()
void publish(Logging.LogEvent e)
java.lang.Class<?> clazz(java.lang.Object obj)
void removeChild(ActorRefImpl<scala.runtime.Nothing$> actor)
void finishTerminate()
boolean watchedActorTerminated(ActorRefImpl<scala.runtime.Nothing$> actor, java.lang.Throwable failure)
Terminated
message
it will be propagated to user's receive.actor
- (undocumented)failure
- (undocumented)void tellWatchersWeDied()
void unwatchWatchedActors()
void addWatcher(ActorRefImpl<scala.runtime.Nothing$> watchee, ActorRefImpl<scala.runtime.Nothing$> watcher)
void remWatcher(ActorRefImpl<scala.runtime.Nothing$> watchee, ActorRefImpl<scala.runtime.Nothing$> watcher)
void addressTerminated(Address address)
<U> U maintainAddressTerminatedSubscription(ActorRefImpl<scala.runtime.Nothing$> change, scala.Function0<U> block)
change
- (undocumented)block
- (undocumented)void unsubscribeAddressTerminated()
void subscribeAddressTerminated()