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

fix: using createUnhandledMessageProbe to avoid message delivered before subscription (#31498)

Browse source
This commit is contained in:
GreyPlane 2022-08-24 14:54:52 +08:00 • committed by GitHub
parent d0a84d1043
commit bd9ecc64ad
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-actor-typed-tests/src/test/scala/akka/actor/typed/scaladsl/ActorContextDelegateSpec.scala
View file

@ -7,7 +7,6 @@ package akka.actor.typed.scaladsl
import akka.actor.UnhandledMessage
import akka.actor.testkit.typed.TestKitSettings
import akka.actor.testkit.typed.scaladsl.{ FishingOutcomes, LogCapturing, ScalaTestWithActorTestKit, TestProbe }
import akka.actor.typed.eventstream.EventStream
import akka.actor.typed.{ ActorRef, Behavior }
import org.scalatest.wordspec.AnyWordSpecLike
@ -71,8 +70,7 @@ class ActorContextDelegateSpec extends ScalaTestWithActorTestKit with AnyWordSpe
}
"publish unhandled message to eventStream as UnhandledMessage and switch to delegator behavior" in {
val deadLetters = TestProbe[UnhandledMessage]("probeDeadLetters")
system.eventStream ! EventStream.Subscribe[UnhandledMessage](deadLetters.ref)
val deadLetters = testKit.createUnhandledMessageProbe()
val probe = TestProbe[Event]()
val behv = Behaviors.setup[PingPongCommand] { implicit context =>