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

=typ fix race condition in AskSpec

Browse source
This commit is contained in:
Johannes Rudolph 2018-02-01 16:17:14 +01:00
parent 3b54f238ea
commit 1a717c02ca
No known key found for this signature in database
GPG key ID: 4D293A24CCD39E19
1 changed files with 3 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -9,6 +9,7 @@ import akka.actor.typed.scaladsl.Behaviors
import akka.actor.typed.scaladsl.Behaviors._
import akka.actor.typed.scaladsl.adapter._
import akka.testkit.typed.TestKit
import akka.testkit.typed.scaladsl.TestProbe
import akka.util.Timeout
import org.scalatest.concurrent.ScalaFutures
@ -41,6 +42,8 @@ class AskSpec extends TestKit("AskSpec") with TypedAkkaSpec with ScalaFutures {
"must fail the future if the actor is already terminated" in {
val ref = spawn(behavior)
(ref ? Stop).futureValue
val probe = TestProbe()
probe.expectTerminated(ref, probe.remainingOrDefault)
val answer = ref ? Foo("bar")
val result = answer.failed.futureValue
result shouldBe a[TimeoutException]