diff --git a/akka-actor-typed-tests/src/test/java/akka/actor/typed/ManualTimerTest.java b/akka-actor-typed-tests/src/test/java/akka/actor/typed/ManualTimerTest.java
deleted file mode 100644
index 606d1b7b9d..0000000000
--- a/akka-actor-typed-tests/src/test/java/akka/actor/typed/ManualTimerTest.java
+++ /dev/null
@@ -1,54 +0,0 @@
-/**
- * Copyright (C) 2017 Lightbend Inc.
- */
-package akka.actor.typed;
-
-//#manual-scheduling-simple
-import java.util.concurrent.TimeUnit;
-import static com.typesafe.config.ConfigFactory.parseString;
-
-import scala.concurrent.duration.Duration;
-
-import akka.actor.typed.javadsl.Behaviors;
-
-import org.junit.Test;
-
-import akka.testkit.typed.TestKit;
-import akka.testkit.typed.javadsl.ExplicitlyTriggeredScheduler;
-import akka.testkit.typed.javadsl.TestProbe;
-
-public class ManualTimerTest extends TestKit {
- ExplicitlyTriggeredScheduler scheduler;
-
- public ManualTimerTest() {
- super(parseString("akka.scheduler.implementation = \"akka.testkit.typed.javadsl.ExplicitlyTriggeredScheduler\""));
- this.scheduler = (ExplicitlyTriggeredScheduler) system().scheduler();
- }
-
- static final class Tick {}
- static final class Tock {}
-
- @Test
- public void testScheduleNonRepeatedTicks() {
- TestProbe probe = TestProbe.create(system());
- Behavior behavior = Behaviors.withTimers(timer -> {
- timer.startSingleTimer("T", new Tick(), Duration.create(10, TimeUnit.MILLISECONDS));
- return Behaviors.immutable( (ctx, tick) -> {
- probe.ref().tell(new Tock());
- return Behaviors.same();
- });
- });
-
- spawn(behavior);
-
- scheduler.expectNoMessageFor(Duration.create(9, TimeUnit.MILLISECONDS), probe);
-
- scheduler.timePasses(Duration.create(2, TimeUnit.MILLISECONDS));
- probe.expectMessageClass(Tock.class);
-
- scheduler.expectNoMessageFor(Duration.create(10, TimeUnit.SECONDS), probe);
- }
-
-
-}
-//#manual-scheduling-simple
diff --git a/akka-actor-typed-tests/src/test/java/akka/actor/typed/javadsl/ActorContextAskTest.java b/akka-actor-typed-tests/src/test/java/akka/actor/typed/javadsl/ActorContextAskTest.java
index 029136ed92..0c936cd546 100644
--- a/akka-actor-typed-tests/src/test/java/akka/actor/typed/javadsl/ActorContextAskTest.java
+++ b/akka-actor-typed-tests/src/test/java/akka/actor/typed/javadsl/ActorContextAskTest.java
@@ -3,11 +3,11 @@
*/
package akka.actor.typed.javadsl;
-import akka.actor.ActorSystem;
import akka.actor.typed.ActorRef;
import akka.actor.typed.Behavior;
import akka.testkit.AkkaJUnitActorSystemResource;
import akka.testkit.AkkaSpec;
+import akka.testkit.typed.javadsl.TestKitJunitResource;
import akka.testkit.typed.javadsl.TestProbe;
import akka.util.Timeout;
import org.junit.ClassRule;
@@ -19,10 +19,7 @@ import java.util.concurrent.TimeUnit;
public class ActorContextAskTest extends JUnitSuite {
@ClassRule
- public static AkkaJUnitActorSystemResource actorSystemResource = new AkkaJUnitActorSystemResource("ActorSelectionTest",
- AkkaSpec.testConf());
-
- private final ActorSystem system = actorSystemResource.getSystem();
+ public static final TestKitJunitResource testKit = new TestKitJunitResource(AkkaSpec.testConf());
static class Ping {
final ActorRef respondTo;
@@ -39,10 +36,8 @@ public class ActorContextAskTest extends JUnitSuite {
return Behaviors.same();
});
- final ActorRef pingPong = Adapter.spawnAnonymous(system, pingPongBehavior);
-
-
- final TestProbe