akka.typed.internal

Class FutureRef<T>

java.lang.Object

akka.typed.ActorRef<T>

akka.typed.internal.WatchableRef<T>

akka.typed.internal.FutureRef<T>

All Implemented Interfaces:

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

public class FutureRef<T>
extends WatchableRef<T>

A Future of an ActorRef can quite easily be wrapped as an ActorRef since no promises are made about delivery delays: as long as the Future is not ready messages will be queued, afterwards they get sent without waiting.

Constructor Summary

Constructors

Constructor and Description
FutureRef(ActorPath _p, int bufferSize, scala.concurrent.Future<ActorRef<T>> f)

Method Summary

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

Methods inherited from class akka.typed.internal.WatchableRef

addWatcher, doTerminate, isAlive, remWatcher, watchedByOffset

Methods inherited from class akka.typed.ActorRef

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

Methods inherited from class java.lang.Object

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

Constructor Detail

FutureRef

public FutureRef(ActorPath _p,
                 int bufferSize,
                 scala.concurrent.Future<ActorRef<T>> f)

Method Detail

targetOffset

public static long targetOffset()

$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()

isAlive

protected static boolean isAlive()

doTerminate

protected static void doTerminate()

addWatcher

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

remWatcher

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

terminate

public void terminate()

Description copied from class: WatchableRef

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

Specified by:

terminate in class WatchableRef<T>

tell

public void tell(T msg)

Specified by:

tell in class WatchableRef<T>

sendSystem

public void sendSystem(SystemMessage signal)

Specified by:

sendSystem in interface ActorRefImpl<T>

Specified by:

sendSystem in class WatchableRef<T>

isLocal

public boolean isLocal()

Specified by:

isLocal in interface ActorRefImpl<T>

Specified by:

isLocal in class WatchableRef<T>