raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Scalariform & add AkkaSpec

Browse source
This commit is contained in:
Roland 2011-10-10 11:12:34 +02:00
parent 67a9a01bff
commit 2599de0381
6 changed files with 19 additions and 13 deletions
Download patch file Download diff file Expand all files Collapse all files

11
akka-testkit/src/main/scala/akka/testkit/TestKit.scala
View file

@ -86,7 +86,7 @@ class TestActor(queue: BlockingDeque[TestActor.Message]) extends Actor with FSM[
* @author Roland Kuhn
* @since 1.1
*/
class TestKit(_app: AkkaApplication = AkkaApplication()) {
class TestKit(_app: AkkaApplication) {
import TestActor.{ Message, RealMessage, NullMessage }
@ -101,14 +101,7 @@ class TestKit(_app: AkkaApplication = AkkaApplication()) {
* ActorRef of the test actor. Access is provided to enable e.g.
* registration as message target.
*/
val testActor = new LocalActorRef(application, Props(new TestActor(queue)).copy(dispatcher = CallingThreadDispatcher.global), "testActor" + TestKit.testActorId.incrementAndGet(), true)
/**
* Implicit sender reference so that replies are possible for messages sent
* from the test class.
*/
@deprecated("will be removed after 1.2, replaced by implicit testActor", "1.2")
val senderOption = Some(testActor)
implicit val testActor: ActorRef = new LocalActorRef(application, Props(new TestActor(queue)).copy(dispatcher = CallingThreadDispatcher.global), "testActor" + TestKit.testActorId.incrementAndGet(), true)
private var end: Duration = Duration.Inf