summaryrefslogtreecommitdiff
path: root/src/actors-migration
diff options
context:
space:
mode:
Diffstat (limited to 'src/actors-migration')
-rw-r--r--src/actors-migration/scala/actors/migration/MigrationSystem.scala (renamed from src/actors-migration/scala/actors/MigrationSystem.scala)5
-rw-r--r--src/actors-migration/scala/actors/migration/Pattern.scala (renamed from src/actors-migration/scala/actors/Pattern.scala)11
-rw-r--r--src/actors-migration/scala/actors/migration/Props.scala (renamed from src/actors-migration/scala/actors/Props.scala)7
-rw-r--r--src/actors-migration/scala/actors/migration/StashingActor.scala (renamed from src/actors-migration/scala/actors/StashingActor.scala)9
-rw-r--r--src/actors-migration/scala/actors/migration/Timeout.scala (renamed from src/actors-migration/scala/actors/Timeout.scala)2
5 files changed, 19 insertions, 15 deletions
diff --git a/src/actors-migration/scala/actors/MigrationSystem.scala b/src/actors-migration/scala/actors/migration/MigrationSystem.scala
index ffc93d9c6f..3dcb38e634 100644
--- a/src/actors-migration/scala/actors/MigrationSystem.scala
+++ b/src/actors-migration/scala/actors/migration/MigrationSystem.scala
@@ -1,10 +1,11 @@
-package scala.actors
+package scala.actors.migration
+import scala.actors._
import scala.collection._
object MigrationSystem {
- private[actors] val contextStack = new ThreadLocal[immutable.Stack[Boolean]] {
+ private[migration] val contextStack = new ThreadLocal[immutable.Stack[Boolean]] {
override def initialValue() = immutable.Stack[Boolean]()
}
diff --git a/src/actors-migration/scala/actors/Pattern.scala b/src/actors-migration/scala/actors/migration/Pattern.scala
index a97ee3ba07..25ba191ce7 100644
--- a/src/actors-migration/scala/actors/Pattern.scala
+++ b/src/actors-migration/scala/actors/migration/Pattern.scala
@@ -1,11 +1,12 @@
-package scala.actors
+package scala.actors.migration
+import scala.actors._
import scala.concurrent.duration.Duration
-import scala.language.implicitConversions
+import language.implicitConversions
object pattern {
- implicit def askSupport(ar: ActorRef): AskableActorRef =
+ implicit def ask(ar: ActorRef): AskableActorRef =
new AskableActorRef(ar)
}
@@ -16,9 +17,9 @@ class AskableActorRef(val ar: ActorRef) extends ActorRef {
def !(message: Any)(implicit sender: ActorRef = null): Unit = ar.!(message)(sender)
- def ?(message: Any)(timeout: Timeout): Future[Any] = ar.?(message, timeout.duration)
+ def ?(message: Any)(implicit timeout: Timeout): scala.concurrent.Future[Any] = ar.?(message, timeout.duration)
- private[actors] def ?(message: Any, timeout: Duration): Future[Any] = ar.?(message, timeout)
+ private[actors] def ?(message: Any, timeout: Duration): scala.concurrent.Future[Any] = ar.?(message, timeout)
def forward(message: Any) = ar.forward(message)
diff --git a/src/actors-migration/scala/actors/Props.scala b/src/actors-migration/scala/actors/migration/Props.scala
index 891e23213a..00bc9d93f8 100644
--- a/src/actors-migration/scala/actors/Props.scala
+++ b/src/actors-migration/scala/actors/migration/Props.scala
@@ -1,4 +1,6 @@
-package scala.actors
+package scala.actors.migration
+
+import scala.actors._
/**
* ActorRef configuration object. It represents the minimal subset of Akka Props class.
@@ -8,6 +10,5 @@ case class Props(creator: () ⇒ InternalActor, dispatcher: String) {
/**
* Returns a new Props with the specified creator set
*/
- def withCreator(c: ⇒ InternalActor) = copy(creator = () ⇒ c)
-
+ final def withCreator(c: ⇒ InternalActor) = copy(creator = () ⇒ c)
}
diff --git a/src/actors-migration/scala/actors/StashingActor.scala b/src/actors-migration/scala/actors/migration/StashingActor.scala
index 775d115d0b..d0a1432e72 100644
--- a/src/actors-migration/scala/actors/StashingActor.scala
+++ b/src/actors-migration/scala/actors/migration/StashingActor.scala
@@ -1,5 +1,7 @@
-package scala.actors
+package scala.actors.migration
+import scala.actors._
+import scala.actors.Actor._
import scala.collection._
import scala.concurrent.duration.Duration
import java.util.concurrent.TimeUnit
@@ -16,7 +18,7 @@ trait StashingActor extends InternalActor {
type Receive = PartialFunction[Any, Unit]
// checks if StashingActor is created within the actorOf block
- creationCheck;
+ creationCheck()
private[actors] val ref = new InternalActorRef(this)
@@ -110,8 +112,7 @@ trait StashingActor extends InternalActor {
/*
* Checks that StashingActor can be created only by MigrationSystem.actorOf method.
*/
- private[this] def creationCheck = {
-
+ private[this] def creationCheck(): Unit = {
// creation check (see ActorRef)
val context = MigrationSystem.contextStack.get
if (context.isEmpty)
diff --git a/src/actors-migration/scala/actors/Timeout.scala b/src/actors-migration/scala/actors/migration/Timeout.scala
index c3017d8569..32ea5f20fc 100644
--- a/src/actors-migration/scala/actors/Timeout.scala
+++ b/src/actors-migration/scala/actors/migration/Timeout.scala
@@ -6,7 +6,7 @@
** |/ **
\* */
-package scala.actors
+package scala.actors.migration
import scala.concurrent.duration.Duration
import java.util.concurrent.TimeUnit