public class TestFSMRef<S,D,T extends Actor> extends TestActorRef<T>
val fsm = TestFSMRef(new Actor with LoggingFSM[Int, Null] {
override def logDepth = 12
startWith(1, null)
when(1) {
case Ev("hello") => goto(2)
}
when(2) {
case Ev("world") => goto(1)
}
}
assert (fsm.stateName == 1)
fsm ! "hallo"
assert (fsm.stateName == 2)
assert (fsm.underlyingActor.getLog == IndexedSeq(FSMLogEntry(1, null, "hallo")))
Constructor and Description |
---|
TestFSMRef(ActorSystem system,
Props props,
ActorRef supervisor,
java.lang.String name,
scala.Predef.$less$colon$less<T,FSM<S,D>> ev) |
Modifier and Type | Method and Description |
---|---|
static void |
$bang(java.lang.Object message,
ActorRef sender) |
static ActorRef |
$bang$default$2(java.lang.Object message) |
protected static ActorContext |
actorContext() |
static <S,D,T extends Actor> |
apply(scala.Function0<T> factory,
ActorRef supervisor,
scala.reflect.ClassTag<T> evidence$4,
scala.Predef.$less$colon$less<T,FSM<S,D>> ev,
ActorSystem system) |
static <S,D,T extends Actor> |
apply(scala.Function0<T> factory,
ActorRef supervisor,
java.lang.String name,
scala.reflect.ClassTag<T> evidence$3,
scala.Predef.$less$colon$less<T,FSM<S,D>> ev,
ActorSystem system) |
static <S,D,T extends Actor> |
apply(scala.Function0<T> factory,
scala.reflect.ClassTag<T> evidence$1,
scala.Predef.$less$colon$less<T,FSM<S,D>> ev,
ActorSystem system) |
static <S,D,T extends Actor> |
apply(scala.Function0<T> factory,
java.lang.String name,
scala.reflect.ClassTag<T> evidence$2,
scala.Predef.$less$colon$less<T,FSM<S,D>> ev,
ActorSystem system) |
void |
cancelTimer(java.lang.String name)
Proxy for
FSM.cancelTimer(java.lang.String) . |
static scala.collection.immutable.Iterable<ActorRef> |
children() |
static int |
compareTo(ActorRef other) |
static MessageDispatcher |
dispatcher() |
static boolean |
equals(java.lang.Object that) |
static void |
forward(java.lang.Object message,
ActorContext context) |
static InternalActorRef |
getChild(scala.collection.Iterator<java.lang.String> names) |
static InternalActorRef |
getParent() |
static InternalActorRef |
getSingleChild(java.lang.String name) |
static int |
hashCode() |
abstract static boolean |
isLocal() |
boolean |
isStateTimerActive()
Proxy for
FSM.isStateTimerActive() . |
static boolean |
isTerminated() |
boolean |
isTimerActive(java.lang.String name)
Proxy for
FSM.isStateTimerActive() . |
protected static ActorCell |
newActorCell(ActorSystemImpl system,
InternalActorRef ref,
Props props,
MessageDispatcher dispatcher,
InternalActorRef supervisor) |
static ActorPath |
path() |
static Props |
props() |
static ActorRefProvider |
provider() |
static void |
receive(java.lang.Object o) |
static void |
receive(java.lang.Object o,
ActorRef sender) |
static void |
restart(java.lang.Throwable cause) |
static void |
resume(java.lang.Throwable causedByFailure) |
static void |
sendSystemMessage(SystemMessage message) |
void |
setState(S stateName,
D stateData,
scala.concurrent.duration.FiniteDuration timeout,
scala.Option<FSM.Reason> stopReason)
Change FSM state; any value left out defaults to the current FSM state
(timeout defaults to None).
|
void |
setTimer(java.lang.String name,
java.lang.Object msg,
scala.concurrent.duration.FiniteDuration timeout,
boolean repeat)
|
static void |
start() |
D |
stateData()
Get current state data of this FSM.
|
S |
stateName()
Get current state name of this FSM.
|
static void |
stop() |
static void |
suspend() |
static void |
tell(java.lang.Object msg,
ActorRef sender) |
static java.lang.String |
toString() |
static ActorCell |
underlying() |
static T |
underlyingActor() |
static ActorRef |
unwatch(ActorRef subject) |
static ActorRef |
watch(ActorRef subject) |
protected static java.lang.Object |
writeReplace() |
apply, apply, apply, apply, apply, apply, apply, apply, apply, apply, create, create, create, create, dispatcher, newActorCell, props, randomName, receive, receive, toString, underlyingActor, unwatch, watch
actorContext, children, getChild, getParent, getSingleChild, isTerminated, path, provider, restart, resume, sendSystemMessage, start, stop, suspend, underlying, writeReplace
isLocal
compareTo, equals, forward, hashCode, noSender, tell
public static <S,D,T extends Actor> TestFSMRef<S,D,T> apply(scala.Function0<T> factory, scala.reflect.ClassTag<T> evidence$1, scala.Predef.$less$colon$less<T,FSM<S,D>> ev, ActorSystem system)
public static <S,D,T extends Actor> TestFSMRef<S,D,T> apply(scala.Function0<T> factory, java.lang.String name, scala.reflect.ClassTag<T> evidence$2, scala.Predef.$less$colon$less<T,FSM<S,D>> ev, ActorSystem system)
public static <S,D,T extends Actor> TestFSMRef<S,D,T> apply(scala.Function0<T> factory, ActorRef supervisor, java.lang.String name, scala.reflect.ClassTag<T> evidence$3, scala.Predef.$less$colon$less<T,FSM<S,D>> ev, ActorSystem system)
public static <S,D,T extends Actor> TestFSMRef<S,D,T> apply(scala.Function0<T> factory, ActorRef supervisor, scala.reflect.ClassTag<T> evidence$4, scala.Predef.$less$colon$less<T,FSM<S,D>> ev, ActorSystem system)
public static final int compareTo(ActorRef other)
public static final void tell(java.lang.Object msg, ActorRef sender)
public static void forward(java.lang.Object message, ActorContext context)
public static final int hashCode()
public static final boolean equals(java.lang.Object that)
public abstract static boolean isLocal()
public static ActorPath path()
protected static ActorContext actorContext()
public static boolean isTerminated()
public static void start()
public static void suspend()
public static void resume(java.lang.Throwable causedByFailure)
public static void stop()
public static InternalActorRef getParent()
public static ActorRefProvider provider()
public static scala.collection.immutable.Iterable<ActorRef> children()
public static InternalActorRef getSingleChild(java.lang.String name)
public static InternalActorRef getChild(scala.collection.Iterator<java.lang.String> names)
public static ActorCell underlying()
public static void sendSystemMessage(SystemMessage message)
public static void $bang(java.lang.Object message, ActorRef sender)
public static void restart(java.lang.Throwable cause)
protected static java.lang.Object writeReplace() throws java.io.ObjectStreamException
java.io.ObjectStreamException
public static ActorRef $bang$default$2(java.lang.Object message)
public static Props props()
public static MessageDispatcher dispatcher()
protected static ActorCell newActorCell(ActorSystemImpl system, InternalActorRef ref, Props props, MessageDispatcher dispatcher, InternalActorRef supervisor)
public static void receive(java.lang.Object o)
public static void receive(java.lang.Object o, ActorRef sender)
public static T underlyingActor()
public static java.lang.String toString()
public S stateName()
public D stateData()
public void setState(S stateName, D stateData, scala.concurrent.duration.FiniteDuration timeout, scala.Option<FSM.Reason> stopReason)
stateName
- (undocumented)stateData
- (undocumented)timeout
- (undocumented)stopReason
- (undocumented)public void setTimer(java.lang.String name, java.lang.Object msg, scala.concurrent.duration.FiniteDuration timeout, boolean repeat)
FSM.setTimer(java.lang.String, java.lang.Object, scala.concurrent.duration.FiniteDuration, boolean)
.name
- (undocumented)msg
- (undocumented)timeout
- (undocumented)repeat
- (undocumented)public void cancelTimer(java.lang.String name)
FSM.cancelTimer(java.lang.String)
.name
- (undocumented)public boolean isTimerActive(java.lang.String name)
FSM.isStateTimerActive()
.name
- (undocumented)public boolean isStateTimerActive()
FSM.isStateTimerActive()
.