path: root/test/files/jvm/actmig-react-receive.scala

import scala.actors.MigrationSystem._
import scala.actors.Actor._
import scala.actors.{ Actor, StashingActor, ActorRef, Props, MigrationSystem, PoisonPill }
import java.util.concurrent.{ TimeUnit, CountDownLatch }
import scala.collection.mutable.ArrayBuffer

object Test {

  def testComposition() = {
      // Snippet showing composition of receives
      // React Snippet - before
      val myActor = actor {
        // do before
        println("do before")
        receive {
          case x: Int =>
            // do task
            println("do task")
        }
        println("do in between")
        receive {
          case x: String =>
            // do string now
            println("do string")
        }
        println("do after")
      }
      myActor.start()
      myActor ! 1
      myActor ! "1"
      Thread.sleep(200)
      // React Snippet - migrated
      val myAkkaActor = MigrationSystem.actorOf(Props(() => new StashingActor {
        override def preStart() = {
          println("do before")
        }

        def receive = ({
          case x: Int =>
            // do task
            println("do task")
        }: Receive) andThen { v =>
          context.become {
              case x: String =>
                //do string
                println("do string")
                context.stop(self)
          }
          println("do in between")
        }

        override def postStop() = {
          println("do after")
        }

      }, "default-stashing-dispatcher"))
      myAkkaActor ! 1
      myAkkaActor ! "1"
      Thread.sleep(200)
    }

  def main(args: Array[String]) = {
    // React Snippet - before
    val myActor = actor {
      // do before
      println("do before")
      receive {
        case x: Int =>
          // do task
          println("do task")
      }
      println("do after")
    }
    myActor.start()
    myActor ! 1
    
    Thread.sleep(200)

    // React Snippet - migrated
    val myAkkaActor = MigrationSystem.actorOf(Props(() => new StashingActor {
      override def preStart() = {
        println("do before")
      }

      def receive = {
        case x: Int =>
          // do task
          println("do task")
          context.stop(self)
      }

      override def postStop() = {
        println("do after")
      }

    }, "default-stashing-dispatcher"))
    myAkkaActor ! 1

    Thread.sleep(200)
    // Starting composition test
    testComposition()

  }
}