chore unit test fixes

Author: Roiocam

akka-actor-typed-tests/src/test/java/akka/actor/typed/eventstream/LoggingDocTest.java

@@ -44,8 +44,10 @@ public void subscribeToDeadLetters() {
         ActorSystem<SpawnProtocol.Command> system = ActorSystem.create(SpawnProtocol.create(),
             "DeadLettersSystem");
         // #subscribe-deadletter
-        ActorRef<DeadLetter> deadLetters = spawn(toClassic(system), DeadLetterActor.create(),
-            "DeadLetters");
+        CompletionStage<ActorRef<DeadLetter>> spawnActorFuture = AskPattern.ask(system,
+            r -> new Spawn<>(DeadLetterActor.create(), "DeadLetters", Props.empty(), r),
+            Duration.ofSeconds(3), system.scheduler());
+        ActorRef<DeadLetter> deadLetters = spawnActorFuture.toCompletableFuture().join();
         system.eventStream().tell(new Subscribe<>(DeadLetter.class, deadLetters));
         // #subscribe-deadletter
         ActorTestKit.shutdown(system);
@@ -189,7 +191,7 @@ public void subscribeToSuppressedDeadLetters() {
         SuppressedDeadLetter suppressedDeadLetter = probe.expectMessageClass(
             SuppressedDeadLetter.class);
         Assert.assertNotNull(suppressedDeadLetter);
-        Assert.assertNotEquals(suppression, suppressedDeadLetter.message());
+        Assert.assertEquals(deadLetter, suppressedDeadLetter);
 
         ActorTestKit.shutdown(system);
     }
@@ -216,10 +218,10 @@ public void subscribeToAllDeadLetters() {
         SuppressedDeadLetter receiveSuppressed = probe.expectMessageClass(
             SuppressedDeadLetter.class);
         Assert.assertNotNull(receiveSuppressed);
-        Assert.assertNotEquals(suppression, receiveSuppressed.message());
+        Assert.assertEquals(suppressedDeadLetter, receiveSuppressed);
         DeadLetter receiveDeadLetter = probe.expectMessageClass(DeadLetter.class);
         Assert.assertNotNull(receiveDeadLetter);
-        Assert.assertNotEquals(deadLetter.message(), receiveDeadLetter.message());
+        Assert.assertEquals(deadLetter, receiveDeadLetter);
 
         ActorTestKit.shutdown(system);
     }

akka-actor-typed-tests/src/test/scala/akka/actor/typed/eventstream/LoggingDocSpec.scala

@@ -143,6 +143,7 @@ class LoggingDocSpec extends ScalaTestWithActorTestKit with AnyWordSpecLike with
     system.eventStream ! Subscribe[AllDeadLetters](listener)
     //#all-deadletters
     val deadLetter = DeadLetter("deadLetter", mockRef, mockRef)
+    system.eventStream ! Publish(deadLetter)
     val receivedDeadLetter = probe.expectMessageType[DeadLetter]
     receivedDeadLetter shouldBe deadLetter
   }