Skip to content

Commit 0bc4ead

Browse files
committed
remove unused imports
1 parent caf0af1 commit 0bc4ead

File tree

1 file changed

+5
-8
lines changed

1 file changed

+5
-8
lines changed

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

Lines changed: 5 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -4,9 +4,6 @@
44

55
package akka.actor.typed.eventstream;
66

7-
import static akka.actor.typed.javadsl.Adapter.spawn;
8-
import static akka.actor.typed.javadsl.Adapter.toClassic;
9-
107
import akka.actor.Actor;
118
import akka.actor.AllDeadLetters;
129
import akka.actor.SuppressedDeadLetter;
@@ -44,11 +41,11 @@ public void subscribeToDeadLetters() {
4441
ActorSystem<SpawnProtocol.Command> system = ActorSystem.create(SpawnProtocol.create(),
4542
"DeadLettersSystem");
4643
// #subscribe-deadletter
47-
CompletionStage<ActorRef<DeadLetter>> spawnActorFuture = AskPattern.ask(system,
48-
r -> new Spawn<>(DeadLetterActor.create(), "DeadLetters", Props.empty(), r),
49-
Duration.ofSeconds(3), system.scheduler());
50-
ActorRef<DeadLetter> deadLetters = spawnActorFuture.toCompletableFuture().join();
51-
system.eventStream().tell(new Subscribe<>(DeadLetter.class, deadLetters));
44+
ActorSystem.create(Behaviors.setup(ctx -> {
45+
ActorRef<DeadLetter> listener = ctx.spawn(DeadLetterActor.create(), "listener");
46+
ctx.getSystem().eventStream().tell(new Subscribe<>(DeadLetter.class, listener));
47+
return Behaviors.empty();
48+
}), "DeadLettersSystem");
5249
// #subscribe-deadletter
5350
ActorTestKit.shutdown(system);
5451
}

0 commit comments

Comments
 (0)