@Test(timeout = 60_000)
public void testScheduleMono() throws Exception {

    AtomicLong tickCounter = new AtomicLong();
    ScheduleReference reference = localScheduler.scheduleMono(
            scheduleDescriptor.toBuilder().withName("testScheduleMono").build(),
            tick -> Mono.delay(Duration.ofMillis(1)).flatMap(t -> {
                tickCounter.incrementAndGet();
                return Mono.empty();
            }),
            Schedulers.parallel()
    );
    testExecutionLifecycle(reference, tickCounter);
}