@Test public void scheduleMessageToRegisteredCrashingActorAndNotAffected() throws Exception { final ActorSystemInstance actorSystem = ActorSystemInstance .getInstance("scheduleMessageToRegisteredCrashingActorAndNotAffected"); new TestAsync<Void>().apply(new Function<CountDownLatch, Void>() { @Override public Void apply(@NonNull CountDownLatch countDownLatch) { MockActorThree actor = new MockActorThree(countDownLatch); actorSystem.register(actor); actor.exception = new UnsupportedOperationException(); ActorScheduler.after(10, actorSystem).send(message, MockActorThree.class); return null; } }); actorSystem.unregister(MockActorThree.class); assertTrue(true); }
@NonNull public static ScheduledMessageSender after(@IntRange(from = 0) long millis) { return after(millis, ActorSystemInstance.getInstance(null)); }
ActorScheduler { @NonNull public static ScheduledMessageSender after(@IntRange(from = 0) long millis) { return after(millis, ActorSystemInstance.getInstance(null)); } }
ActorScheduler { @NonNull public static ScheduledMessageSender after(@IntRange(from = 0) long millis) { return after(millis, ActorSystemInstance.getInstance(null)); } ActorScheduler(); }
ActorScheduler { @NonNull public static ScheduledMessageSender after(@IntRange(from = 0) long millis) { return after(millis, ActorSystemInstance.getInstance(null)); } ActorScheduler(); @NonNull static ScheduledMessageSender after(@IntRange(from = 0) long millis); static void cancel(@NonNull Class<?> actorAddress); }
ActorScheduler { @NonNull public static ScheduledMessageSender after(@IntRange(from = 0) long millis) { return after(millis, ActorSystemInstance.getInstance(null)); } ActorScheduler(); @NonNull static ScheduledMessageSender after(@IntRange(from = 0) long millis); static void cancel(@NonNull Class<?> actorAddress);  }