akka.typed.internal

Class WatchableRef<T>

java.lang.Object

akka.typed.ActorRef<T>

akka.typed.internal.WatchableRef<T>

All Implemented Interfaces:

ActorRefImpl<T>, java.lang.Comparable<ActorRef<scala.runtime.Nothing$>>

Direct Known Subclasses:

FunctionRef, FutureRef

public abstract class WatchableRef<T>
extends ActorRef<T>
implements ActorRefImpl<T>

The mechanics for synthetic ActorRefs that have a lifecycle and support being watched.

Constructor Summary

Constructors

Constructor and Description
WatchableRef(ActorPath _p)

Method Summary

Modifier and Type	Method and Description
static void	$bang(T msg)
protected void	addWatcher(ActorRefImpl<scala.runtime.Nothing$> watcher)
static int	compareTo(ActorRef<scala.runtime.Nothing$> other)
protected void	doTerminate()
static boolean	equals(java.lang.Object that)
static int	hashCode()
protected boolean	isAlive()
abstract static boolean	isLocal()
static ActorPath	path()
protected void	remWatcher(ActorRefImpl<scala.runtime.Nothing$> watcher)
abstract static void	sendSystem(SystemMessage signal)
abstract static void	tell(T msg)
protected abstract void	terminate() Callback that is invoked when this ref has terminated.
static java.lang.String	toString()
static <U> ActorRef<U>	upcast()
static long	watchedByOffset()

Methods inherited from class akka.typed.ActorRef

apply, apply, compareTo, equals, FunctionPath, FuturePath, hashCode, path, tell, toString, upcast

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface akka.typed.internal.ActorRefImpl

isLocal, sendSystem

Constructor Detail

WatchableRef

public WatchableRef(ActorPath _p)

Method Detail

watchedByOffset

public static long watchedByOffset()

tell

public abstract static void tell(T msg)

$bang

public static void $bang(T msg)

upcast

public static <U> ActorRef<U> upcast()

path

public static final ActorPath path()

compareTo

public static final int compareTo(ActorRef<scala.runtime.Nothing$> other)

hashCode

public static final int hashCode()

equals

public static final boolean equals(java.lang.Object that)

toString

public static final java.lang.String toString()

sendSystem

public abstract static void sendSystem(SystemMessage signal)

isLocal

public abstract static boolean isLocal()

terminate

protected abstract void terminate()

Callback that is invoked when this ref has terminated. Even if doTerminate() is called multiple times, this callback is invoked only once.

isAlive

protected boolean isAlive()

doTerminate

protected void doTerminate()

addWatcher

protected final void addWatcher(ActorRefImpl<scala.runtime.Nothing$> watcher)

remWatcher

protected final void remWatcher(ActorRefImpl<scala.runtime.Nothing$> watcher)