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

Merge pull request #22856 from johanandren/wip-22753-move-typed-inbox-to-testkit-johanandren

Browse source 
Moved typed inbox to testkit
This commit is contained in:
Patrik Nordwall 2017-05-05 14:44:36 +02:00 • committed by GitHub
commit 0428bc82d2
9 changed files with 20 additions and 16 deletions
Download patch file Download diff file Expand all files Collapse all files

15
akka-typed/src/main/scala/akka/typed/Inbox.scala → akka-typed-testkit/src/main/scala/akka/typed/testkit/Inbox.scala
View file

@ -1,16 +1,15 @@
/**
* Copyright (C) 2014-2017 Lightbend Inc. <http://www.lightbend.com>
*/
package akka.typed
package akka.typed.testkit
import java.util.concurrent.{ ConcurrentLinkedQueue, ThreadLocalRandom }
import akka.actor.{ Address, RootActorPath }
import akka.typed.{ ActorRef, internal }
import java.util.concurrent.ConcurrentLinkedQueue
import akka.actor.ActorPath
import akka.actor.RootActorPath
import akka.actor.Address
import scala.collection.immutable
import scala.annotation.tailrec
import akka.actor.ActorRefProvider
import java.util.concurrent.ThreadLocalRandom
import scala.collection.immutable
/**
* Utility for receiving messages outside of an actor. No methods are provided

2
akka-typed-tests/src/test/scala/akka/typed/BehaviorSpec.scala
View file

@ -10,7 +10,7 @@ import akka.japi.pf.{ FI, PFBuilder }
import java.util.function.{ Function ⇒ F1 }
import akka.Done
import akka.typed.testkit.EffectfulActorContext
import akka.typed.testkit.{ EffectfulActorContext, Inbox }
class BehaviorSpec extends TypedSpec {

4
akka-typed-tests/src/test/scala/akka/typed/DeferredSpec.scala
View file

@ -6,12 +6,10 @@ package akka.typed
import scala.concurrent.Await
import scala.concurrent.duration._
import scala.util.control.NoStackTrace
import akka.typed.scaladsl.Actor
import akka.typed.scaladsl.Actor.BehaviorDecorators
import akka.typed.scaladsl.AskPattern._
import akka.typed.testkit.EffectfulActorContext
import akka.typed.testkit.TestKitSettings
import akka.typed.testkit.{ EffectfulActorContext, Inbox, TestKitSettings }
import akka.typed.testkit.scaladsl._
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])

5
akka-typed-tests/src/test/scala/akka/typed/RestarterSpec.scala
View file

@ -5,11 +5,12 @@ package akka.typed
import scala.concurrent.duration._
import akka.typed.scaladsl.Actor._
import akka.typed.testkit.EffectfulActorContext
import akka.typed.testkit.{ EffectfulActorContext, Inbox, TestKitSettings }
import scala.util.control.NoStackTrace
import akka.typed.testkit.TestKitSettings
import akka.typed.testkit.scaladsl._
import akka.typed.scaladsl.AskPattern._
import scala.concurrent.Await
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])

3
akka-typed-tests/src/test/scala/akka/typed/TypedSpec.scala
View file

@ -29,8 +29,9 @@ import org.junit.runner.RunWith
import scala.util.control.NonFatal
import org.scalatest.exceptions.TestFailedException
import akka.typed.scaladsl.AskPattern
import scala.util.control.NoStackTrace
import akka.typed.testkit.TestKitSettings
import akka.typed.testkit.{ Inbox, TestKitSettings }
/**
* Helper class for writing tests for typed Actors with ScalaTest.

1
akka-typed-tests/src/test/scala/akka/typed/internal/ActorSystemSpec.scala
View file

@ -7,6 +7,7 @@ package internal
import akka.Done
import akka.typed.scaladsl.Actor
import akka.typed.scaladsl.Actor._
import akka.typed.testkit.Inbox
import akka.util.Timeout
import org.junit.runner.RunWith
import org.scalactic.ConversionCheckedTripleEquals

3
akka-typed-tests/src/test/scala/akka/typed/internal/ActorSystemStub.scala
View file

@ -5,9 +5,12 @@ package akka.typed
package internal
import akka.{ actor ⇒ a, event ⇒ e }
import scala.concurrent._
import com.typesafe.config.ConfigFactory
import java.util.concurrent.ThreadFactory
import akka.typed.testkit.Inbox
import akka.util.Timeout
private[typed] class ActorSystemStub(val name: String)

1
akka-typed-tests/src/test/scala/akka/typed/internal/EventStreamSpec.scala
View file

@ -8,6 +8,7 @@ import akka.Done
import akka.event.Logging._
import akka.typed.scaladsl.Actor._
import akka.typed.scaladsl.AskPattern._
import akka.typed.testkit.Inbox
import com.typesafe.config.ConfigFactory
import org.scalatest.concurrent.Eventually
import org.scalatest.concurrent.PatienceConfiguration.Timeout

2
akka-typed-tests/src/test/scala/akka/typed/patterns/ReceptionistSpec.scala
View file

@ -10,7 +10,7 @@ import scala.concurrent.duration._
import akka.typed._
import akka.typed.scaladsl.Actor
import akka.typed.scaladsl.Actor._
import akka.typed.testkit.{ Effect, EffectfulActorContext }
import akka.typed.testkit.{ Effect, EffectfulActorContext, Inbox }
class ReceptionistSpec extends TypedSpec {