spring_boot_starter_scheduling 0.3.2

Scheduling starter for spring_boot_dart: @Scheduled methods with fixed rate, fixed delay or cron expressions, a TaskScheduler bean, stopped with the context.

example/example.dart

// Scheduled tasks in a Spring Boot application: @Scheduled methods on a
// bean; the generator registers them and picks the starter up
// (example.spring.dart, from `dart run build_runner build`).
//
//   dart run example/example.dart
//   dart run example/example.dart --heartbeat.rate=500ms
import 'dart:async';

import 'package:spring_boot_starter_scheduling/spring_boot_starter_scheduling.dart';

import 'example.spring.dart';

@Component()
class Heartbeat {
  var beats = 0;

  /// Every second, or `heartbeat.rate`.
  @Scheduled(fixedRateString: r'${heartbeat.rate:1s}')
  void beat() => print('beat ${++beats}');

  /// Every 2 seconds, by a cron expression (with seconds).
  @Scheduled(cron: '*/2 * * * * *')
  Future<void> report() async => print('report at ${DateTime.now()}');
}

/// Code can schedule work too, through the `TaskScheduler` bean.
@Component()
class Reminder implements CommandLineRunner {
  Reminder(this.scheduler);

  final TaskScheduler scheduler;

  @override
  void run(List<String> args) => scheduler.schedule(
    () => print('one-off after 1.5 s'),
    OneShotTrigger(scheduler.now().add(const Duration(milliseconds: 1500))),
  );
}

@SpringBootApplication()
Future<void> main(List<String> args) async {
  // Scheduled tasks keep an application running; this one stops after
  // three seconds. Closing the context cancels every task.
  final context = runApplication(args);
  await Future<void>.delayed(const Duration(seconds: 3));
  final heartbeat = context.getBean<Heartbeat>();
  await context.closeAsync();
  print('${heartbeat.beats} beats');
}