public class TestFSMRef<S,D,T extends akka.actor.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(akka.actor.ActorSystem system,
akka.actor.Props props,
akka.actor.ActorRef supervisor,
java.lang.String name,
scala.Predef.$less$colon$less<T,akka.actor.FSM<S,D>> ev) |
Modifier and Type | Method and Description |
---|---|
static <S,D,T extends akka.actor.Actor> |
apply(scala.Function0<T> factory,
akka.actor.ActorRef supervisor,
scala.reflect.ClassTag<T> evidence$4,
scala.Predef.$less$colon$less<T,akka.actor.FSM<S,D>> ev,
akka.actor.ActorSystem system) |
static <S,D,T extends akka.actor.Actor> |
apply(scala.Function0<T> factory,
akka.actor.ActorRef supervisor,
java.lang.String name,
scala.reflect.ClassTag<T> evidence$3,
scala.Predef.$less$colon$less<T,akka.actor.FSM<S,D>> ev,
akka.actor.ActorSystem system) |
static <S,D,T extends akka.actor.Actor> |
apply(scala.Function0<T> factory,
scala.reflect.ClassTag<T> evidence$1,
scala.Predef.$less$colon$less<T,akka.actor.FSM<S,D>> ev,
akka.actor.ActorSystem system) |
static <S,D,T extends akka.actor.Actor> |
apply(scala.Function0<T> factory,
java.lang.String name,
scala.reflect.ClassTag<T> evidence$2,
scala.Predef.$less$colon$less<T,akka.actor.FSM<S,D>> ev,
akka.actor.ActorSystem system) |
void |
cancelTimer(java.lang.String name)
Proxy for
FSM.cancelTimer(java.lang.String) . |
boolean |
isStateTimerActive()
Proxy for
FSM.isStateTimerActive() . |
boolean |
isTimerActive(java.lang.String name)
Proxy for
FSM.isStateTimerActive() . |
void |
setState(S stateName,
D stateData,
scala.concurrent.duration.FiniteDuration timeout,
scala.Option<akka.actor.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)
Proxy for
FSM.setTimer(java.lang.String, java.lang.Object, scala.concurrent.duration.FiniteDuration, boolean) . |
D |
stateData()
Get current state data of this FSM.
|
S |
stateName()
Get current state name of this FSM.
|
apply, apply, apply, apply, apply, apply, apply, apply, apply, apply, create, create, create, create, dispatcher, newActorCell, props, randomName, receive, receive, toString, underlyingActor, unwatch, watch
$bang, $bang$default$2, actorContext, children, getChild, getParent, getSingleChild, isLocal, isTerminated, path, provider, restart, resume, sendSystemMessage, start, stop, suspend, underlying, writeReplace
public static <S,D,T extends akka.actor.Actor> TestFSMRef<S,D,T> apply(scala.Function0<T> factory, scala.reflect.ClassTag<T> evidence$1, scala.Predef.$less$colon$less<T,akka.actor.FSM<S,D>> ev, akka.actor.ActorSystem system)
public static <S,D,T extends akka.actor.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,akka.actor.FSM<S,D>> ev, akka.actor.ActorSystem system)
public static <S,D,T extends akka.actor.Actor> TestFSMRef<S,D,T> apply(scala.Function0<T> factory, akka.actor.ActorRef supervisor, java.lang.String name, scala.reflect.ClassTag<T> evidence$3, scala.Predef.$less$colon$less<T,akka.actor.FSM<S,D>> ev, akka.actor.ActorSystem system)
public static <S,D,T extends akka.actor.Actor> TestFSMRef<S,D,T> apply(scala.Function0<T> factory, akka.actor.ActorRef supervisor, scala.reflect.ClassTag<T> evidence$4, scala.Predef.$less$colon$less<T,akka.actor.FSM<S,D>> ev, akka.actor.ActorSystem system)
public S stateName()
public D stateData()
public void setState(S stateName, D stateData, scala.concurrent.duration.FiniteDuration timeout, scala.Option<akka.actor.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()
.