object Effect
- Alphabetic
- By Inheritance
- Effect
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- final case class AskInitiated[Req, Res, T](target: RecipientRef[Req], responseTimeout: FiniteDuration, responseClass: Class[Res])(askMessage: Req, forwardResponse: (Try[Res]) => Unit, mapResponse: (Try[Res]) => T) extends Effect with Product with Serializable
The behavior initiated an ask via its context.
The behavior initiated an ask via its context. A response or timeout may be sent via this effect to the asking behavior: this effect enforces that at most one response or timeout is sent. Alternatively, one may, after obtaining the effect, test the response adaptation function (without sending a message to the asking behavior) arbitrarily many times via the 'adaptResponse
and
adaptTimeoutmethods.
The 'replyToRef' is exposed so that the target inbox can expect the actual message sent to initiate the ask.
Note that this requires the ask to be initiated via the ActorContext. The Future returning ask is not testable in the BehaviorTestKit.
- final case class MessageAdapter[A, T](messageClass: Class[A], adapt: (A) => T) extends Effect with Product with Serializable
The behavior create a message adapter for the messages of type clazz
- sealed abstract class NoEffects extends Effect
Used for NoEffects expectations by type
- sealed abstract class ReceiveTimeoutCancelled extends Effect
- final case class ReceiveTimeoutSet[T](d: FiniteDuration, message: T) extends Effect with Product with Serializable
The behavior set a new receive timeout, with
message
as timeout notification - final case class Scheduled[U](delay: FiniteDuration, target: typed.ActorRef[U], message: U) extends Effect with Product with Serializable
The behavior used
context.scheduleOnce
to schedulemessage
to be sent totarget
afterdelay
FIXME what about events scheduled through the scheduler? - final class Spawned[T] extends Effect with Product3[Behavior[T], String, typed.Props] with Serializable
The behavior spawned a named child with the given behavior (and optionally specific props)
- final class SpawnedAnonymous[T] extends Effect with Product2[Behavior[T], typed.Props] with Serializable
The behavior spawned an anonymous child with the given behavior (and optionally specific props)
- final case class Stopped(childName: String) extends Effect with Product with Serializable
The behavior stopped
childName
- final case class TimerCancelled(key: Any) extends Effect with Product with Serializable
- final case class TimerScheduled[U](key: Any, msg: U, delay: FiniteDuration, mode: TimerMode, overriding: Boolean)(send: () => Unit) extends Effect with Product with Serializable
- final case class Unwatched[T](other: typed.ActorRef[T]) extends Effect with Product with Serializable
The behavior stopped watching
other
, throughcontext.unwatch(other)
- final case class Watched[T](other: typed.ActorRef[T]) extends Effect with Product with Serializable
The behavior started watching
other
, throughcontext.watch(other)
- final case class WatchedWith[U, T](other: typed.ActorRef[U], message: T) extends Effect with Product with Serializable
The behavior started watching
other
, throughcontext.watchWith(other, message)
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def timerScheduled: TimerScheduled
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- case object NoEffects extends NoEffects with Product with Serializable
Used to represent an empty list of effects - in other words, the behavior didn't do anything observable
- case object ReceiveTimeoutCancelled extends ReceiveTimeoutCancelled with Product with Serializable
- object Spawned extends Serializable
- object SpawnedAnonymous extends Serializable
- object TimerScheduled extends Serializable