Scala example source code file (ReplyReactorTask.scala)

This example Scala source code file (ReplyReactorTask.scala) is included in my "Source Code Warehouse" project. The intent of this project is to help you more easily find Scala source code examples by using tags.

All credit for the original source code belongs to scala-lang.org; I'm just trying to make examples easier to find. (For my Scala work, see my Scala examples and tutorials.)

Scala tags/keywords

actor, any, internalreplyreactor, partialfunction, reactortask, replyreactortask, unit

The ReplyReactorTask.scala Scala example source code

/*                     __                                               *\
**     ________ ___   / /  ___     Scala API                            **
**    / __/ __// _ | / /  / _ |    (c) 2005-2013, LAMP/EPFL             **
**  __\ \/ /__/ __ |/ /__/ __ |                                         **
** /____/\___/_/ |_/____/_/ | |                                         **
**                          |/                                          **
\*                                                                      */

// $Id$

package scala.actors

/**
 *  @author Philipp Haller
 *  @note   This class inherits a public var called 'reactor' from ReactorTask,
 *  and also defines a constructor parameter which shadows it (which makes any
 *  changes to the underlying var invisible.) I can't figure out what's supposed
 *  to happen, so I renamed the constructor parameter to at least be less confusing.
 */
private[actors] class ReplyReactorTask(replyReactor: InternalReplyReactor,
                                       fun: () => Unit,
                                       handler: PartialFunction[Any, Any],
                                       msg: Any)
  extends ReactorTask(replyReactor, fun, handler, msg) {

  var saved: InternalReplyReactor = _

  protected override def beginExecution() {
    saved = Actor.tl.get
    // !!! If this is supposed to be setting the current contents of the
    // inherited mutable var rather than always the value given in the constructor,
    // then it should be changed to "set reactor".
    Actor.tl set replyReactor
  }

  protected override def suspendExecution() {
    Actor.tl set saved
  }

}