case class Stage[T](actions: List[ReactorAction[T]] = Nil) extends Product with Serializable
- Alphabetic
- By Inheritance
- Stage
- Serializable
- Product
- Equals
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new Stage(actions: List[ReactorAction[T]] = Nil)
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
- val actions: List[ReactorAction[T]]
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def loop(body: => Stage[T]): Stage[T]
Executes the body in a loop.
Executes the body in a loop.
- body
The Stage to be executes repeatedly
- def modify(modifier: (T) => T): Stage[T]
Modifies the value of the Reactor.
Modifies the value of the Reactor.
- modifier
A function that has the old Reactor value as input and returns a new Reactor value.
- returns
A StageBuilder describing the Reactor behaviour.
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def next(event: Api.Event[Unit])(body: => Stage[T]): Stage[T]
Waits until the event is triggered.
Waits until the event is triggered.
When the event is triggered the given body is executed in the same transaction.
- event
the event to wait for.
- body
the code to execute when the event is triggered.
- def next[E](event: Api.Event[E])(body: (E) => Stage[T]): Stage[T]
Waits until the event is triggered.
Waits until the event is triggered.
When the event is triggered the given body is executed in the same transaction.
- E
the event's type.
- event
the event to wait for.
- body
the code to execute when the event is triggered.
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- def read(body: (T) => Stage[T]): Stage[T]
Reads the current reactor value.
- def set(newValue: T): Stage[T]
Sets the value of the Reactor.
Sets the value of the Reactor.
- newValue
The new value of the Reactor.
- returns
A StageBuilder describing the Reactor behaviour.
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def until(event: Api.Event[Any], body: => Stage[T]): Stage[T]
Executes it's body until an event is fired.
Executes it's body until an event is fired.
Until executes the body until the given event is fired.
- event
The event indicating the interrupt.
- body
The Stage to be executes by default.
- def until(event: Api.Event[Unit], body: => Stage[T], interruptHandler: Stage[T]): Stage[T]
Executes it's body until an event is fired.
Executes it's body until an event is fired.
Until executes the body until the given event is fired. When the event is fired, until executes the interruptHandler.
- def until[E](event: Api.Event[E], body: => Stage[T], interruptHandler: (E) => Stage[T]): Stage[T]
Executes it's body until an event is fired.
Executes it's body until an event is fired.
Until executes the body until the given event is fired. When the event is fired, until executes the interruptHandler.
- 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])
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])