public abstract class ActorRef<T> extends java.lang.Object implements java.lang.Comparable<ActorRef<scala.runtime.Nothing$>>
DeadLetter
channel of the
EventStream
on a best effort basis
(i.e. this delivery is not reliable).Modifier and Type | Method and Description |
---|---|
static <T> ActorRef<T> |
apply(scala.Function2<T,FunctionRef<T>,scala.runtime.BoxedUnit> send,
scala.Function1<FunctionRef<T>,scala.runtime.BoxedUnit> terminate)
Create an ActorRef by providing a function that is invoked for sending
messages and a termination callback.
|
static <T> ActorRef<T> |
apply(scala.concurrent.Future<ActorRef<T>> f,
int bufferSize)
Create an ActorRef from a Future, buffering up to the given number of
messages in while the Future is not fulfilled.
|
int |
compareTo(ActorRef<scala.runtime.Nothing$> other)
Comparison takes path and the unique id of the actor cell into account.
|
boolean |
equals(java.lang.Object that)
Equals takes path and the unique id of the actor cell into account.
|
static RootActorPath |
FunctionPath() |
static RootActorPath |
FuturePath()
Create an ActorRef by providing a function that is invoked for sending
messages and a termination callback.
|
int |
hashCode() |
ActorPath |
path()
The hierarchical path name of the referenced Actor.
|
abstract void |
tell(T msg)
Send a message to the Actor referenced by this ActorRef using *at-most-once*
messaging semantics.
|
java.lang.String |
toString() |
<U> ActorRef<U> |
upcast()
Unsafe utility method for widening the type accepted by this ActorRef;
provided to avoid having to use
asInstanceOf on the full reference type,
which would unfortunately also work on non-ActorRefs. |
public ActorRef(ActorPath _path)
public static <T> ActorRef<T> apply(scala.concurrent.Future<ActorRef<T>> f, int bufferSize)
f
- (undocumented)bufferSize
- (undocumented)public static <T> ActorRef<T> apply(scala.Function2<T,FunctionRef<T>,scala.runtime.BoxedUnit> send, scala.Function1<FunctionRef<T>,scala.runtime.BoxedUnit> terminate)
send
- (undocumented)terminate
- (undocumented)public static RootActorPath FuturePath()
public static RootActorPath FunctionPath()
public abstract void tell(T msg)
msg
- (undocumented)public <U> ActorRef<U> upcast()
asInstanceOf
on the full reference type,
which would unfortunately also work on non-ActorRefs.public final ActorPath path()
ActorPath
and more than one Actor instance can exist with the same path at different
points in time, but not concurrently.public final int compareTo(ActorRef<scala.runtime.Nothing$> other)
compareTo
in interface java.lang.Comparable<ActorRef<scala.runtime.Nothing$>>
other
- (undocumented)public final int hashCode()
hashCode
in class java.lang.Object
public final boolean equals(java.lang.Object that)
equals
in class java.lang.Object
that
- (undocumented)public final java.lang.String toString()
toString
in class java.lang.Object