akka.typed.internal

Class FunctionRef<T>

java.lang.Object

akka.typed.ActorRef<T>

akka.typed.internal.WatchableRef<T>

akka.typed.internal.FunctionRef<T>

All Implemented Interfaces:

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

public final class FunctionRef<T>
extends WatchableRef<T>

A local synchronous ActorRef that invokes the given function for every message send. This reference can be watched and will do the right thing when it receives a DeathWatchNotification. This reference cannot watch other references.

Constructor Summary

Constructors

Constructor and Description
FunctionRef(ActorPath _path, scala.Function2<T,FunctionRef<T>,scala.runtime.BoxedUnit> send, scala.Function1<FunctionRef<T>,scala.runtime.BoxedUnit> _terminate)

Method Summary

Modifier and Type	Method and Description
boolean	isLocal()
void	sendSystem(SystemMessage signal)
void	tell(T msg)
void	terminate() Callback that is invoked when this ref has terminated.

Methods inherited from class akka.typed.internal.WatchableRef

$bang, addWatcher, compareTo, doTerminate, equals, hashCode, isAlive, path, remWatcher, toString, upcast, 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

FunctionRef

public FunctionRef(ActorPath _path,
                   scala.Function2<T,FunctionRef<T>,scala.runtime.BoxedUnit> send,
                   scala.Function1<FunctionRef<T>,scala.runtime.BoxedUnit> _terminate)

Method Detail

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>

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>