Reactor

Abstract Value Members

abstract def act(): Unit

The reactor's behavior is specified by implementing this method.

Concrete Value Members

def !(msg: Msg): Unit

Sends msg to this reactor (asynchronous).
Sends msg to this reactor (asynchronous).
msg
the message to send

Definition Classes
Reactor → OutputChannel
final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
def +(other: String): String

Implicit information
This member is added by an implicit conversion from Reactor[Msg] to any2stringadd[Reactor[Msg]] performed by method any2stringadd in scala.Predef.
Definition Classes
any2stringadd
def ->[B](y: B): (Reactor[Msg], B)

Implicit information
This member is added by an implicit conversion from Reactor[Msg] to ArrowAssoc[Reactor[Msg]] performed by method ArrowAssoc in scala.Predef.
Definition Classes
ArrowAssoc
Annotations
@inline()
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
def continue(): Unit

Continues with the execution of the closure registered as continuation following andThen.
Continues with the execution of the closure registered as continuation following andThen. Continues with the execution of the next loop iteration when invoked inside the body of loop or loopWhile.

Definition Classes
Combinators
def ensuring(cond: (Reactor[Msg]) ⇒ Boolean, msg: ⇒ Any): Reactor[Msg]

Implicit information
This member is added by an implicit conversion from Reactor[Msg] to Ensuring[Reactor[Msg]] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
def ensuring(cond: (Reactor[Msg]) ⇒ Boolean): Reactor[Msg]

Implicit information
This member is added by an implicit conversion from Reactor[Msg] to Ensuring[Reactor[Msg]] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
def ensuring(cond: Boolean, msg: ⇒ Any): Reactor[Msg]

Implicit information
This member is added by an implicit conversion from Reactor[Msg] to Ensuring[Reactor[Msg]] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
def ensuring(cond: Boolean): Reactor[Msg]

Implicit information
This member is added by an implicit conversion from Reactor[Msg] to Ensuring[Reactor[Msg]] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def exceptionHandler: PartialFunction[Exception, Unit]

This partial function is applied to exceptions that propagate out of this reactor's body.
This partial function is applied to exceptions that propagate out of this reactor's body.

Attributes
protected[scala.actors]
def exit(): Nothing

Attributes
protected[scala.actors]
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
def formatted(fmtstr: String): String

Implicit information
This member is added by an implicit conversion from Reactor[Msg] to StringFormat[Reactor[Msg]] performed by method StringFormat in scala.Predef.
Definition Classes
StringFormat
Annotations
@inline()
def forward(msg: Msg): Unit

Forwards msg to this reactor (asynchronous).
Forwards msg to this reactor (asynchronous).
msg
the message to forward

Definition Classes
Reactor → OutputChannel
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
def getState: Actor.State.Value

Returns the execution state of this reactor.
Returns the execution state of this reactor.
returns
the execution state
def hashCode(): Int

Definition Classes
AnyRef → Any
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
def loop(body: ⇒ Unit): Unit

Repeatedly executes body.
Repeatedly executes body.
body
the block to be executed

Definition Classes
Combinators
def loopWhile(cond: ⇒ Boolean)(body: ⇒ Unit): Unit

Repeatedly executes body while the condition cond is true.
Repeatedly executes body while the condition cond is true.
cond
the condition to test
body
the block to be executed

Definition Classes
Combinators
def mailboxSize: Int

Attributes
protected[scala.actors]
implicit def mkBody[A](body: ⇒ A): Body[A]

Enables the composition of suspendable closures using andThen, loop, loopWhile, etc.
Enables the composition of suspendable closures using andThen, loop, loopWhile, etc.

Definition Classes
Reactor → Combinators
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
def react(handler: PartialFunction[Msg, Unit]): Nothing

Receives a message from this reactor's mailbox.
Receives a message from this reactor's mailbox.
This method never returns. Therefore, the rest of the computation has to be contained in the actions of the partial function.
handler
a partial function with message patterns and actions

Attributes
protected
def receiver: Actor

Returns the Actor that is receiving from this reactor.
Returns the Actor that is receiving from this reactor.

Definition Classes
Reactor → OutputChannel
def restart(): Unit

Restarts this reactor.
Restarts this reactor.

Exceptions thrown
java.lang.IllegalStateException
if the reactor is not in state Actor.State.Terminated
def scheduler: IScheduler

Attributes
protected[scala.actors]
def send(msg: Msg, replyTo: OutputChannel[Any]): Unit

Sends msg to this reactor (asynchronous) supplying explicit reply destination.
Sends msg to this reactor (asynchronous) supplying explicit reply destination.
msg
the message to send
replyTo
the reply destination

Definition Classes
Reactor → OutputChannel
def start(): Reactor[Msg]

Starts this reactor.
Starts this reactor. This method is idempotent.
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toString(): String

Definition Classes
AnyRef → Any
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
def →[B](y: B): (Reactor[Msg], B)

Implicit information
This member is added by an implicit conversion from Reactor[Msg] to ArrowAssoc[Reactor[Msg]] performed by method ArrowAssoc in scala.Predef.
Definition Classes
ArrowAssoc

Inherited from Combinators

Inherited from OutputChannel[Msg]

Inherited from AnyRef

Inherited from Any

Inherited by implicit conversion any2stringadd from Reactor[Msg] to any2stringadd[Reactor[Msg]]

Inherited by implicit conversion StringFormat from Reactor[Msg] to StringFormat[Reactor[Msg]]

Inherited by implicit conversion Ensuring from Reactor[Msg] to Ensuring[Reactor[Msg]]

Inherited by implicit conversion ArrowAssoc from Reactor[Msg] to ArrowAssoc[Reactor[Msg]]

Ungrouped

trait Reactor[Msg >: Null] extends OutputChannel[Msg] with Combinators

Abstract Value Members

abstract def act(): Unit

Concrete Value Members

def !(msg: Msg): Unit

final def !=(arg0: Any): Boolean

final def ##(): Int

def +(other: String): String

def ->[B](y: B): (Reactor[Msg], B)

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

def clone(): AnyRef

def continue(): Unit

def ensuring(cond: (Reactor[Msg]) ⇒ Boolean, msg: ⇒ Any): Reactor[Msg]

def ensuring(cond: (Reactor[Msg]) ⇒ Boolean): Reactor[Msg]

def ensuring(cond: Boolean, msg: ⇒ Any): Reactor[Msg]

def ensuring(cond: Boolean): Reactor[Msg]

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def exceptionHandler: PartialFunction[Exception, Unit]

def exit(): Nothing

def finalize(): Unit

def formatted(fmtstr: String): String

def forward(msg: Msg): Unit

final def getClass(): Class[_]

def getState: Actor.State.Value

def hashCode(): Int

final def isInstanceOf[T0]: Boolean

def loop(body: ⇒ Unit): Unit

def loopWhile(cond: ⇒ Boolean)(body: ⇒ Unit): Unit

def mailboxSize: Int

implicit def mkBody[A](body: ⇒ A): Body[A]

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def react(handler: PartialFunction[Msg, Unit]): Nothing

def receiver: Actor

def restart(): Unit

def scheduler: IScheduler

def send(msg: Msg, replyTo: OutputChannel[Any]): Unit

def start(): Reactor[Msg]

final def synchronized[T0](arg0: ⇒ T0): T0

def toString(): String

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

def →[B](y: B): (Reactor[Msg], B)

Inherited from Combinators

Inherited from OutputChannel[Msg]

Inherited from AnyRef

Inherited from Any

Inherited by implicit conversion any2stringadd from Reactor[Msg] to any2stringadd[Reactor[Msg]]

Inherited by implicit conversion StringFormat from Reactor[Msg] to StringFormat[Reactor[Msg]]

Inherited by implicit conversion Ensuring from Reactor[Msg] to Ensuring[Reactor[Msg]]

Inherited by implicit conversion ArrowAssoc from Reactor[Msg] to ArrowAssoc[Reactor[Msg]]

Ungrouped