start method

Loads the workflow once and starts watching for changes.

Implementation

Future<WorkflowReload> start() async {
  final initial = await _loadOnce();
  _lastDefinition = initial.definition;
  _lastConfig = initial.config;

  final file = File(workflowPath);
  if (file.existsSync()) {
    _watcher = FileWatcher(file.absolute.path);
    _sub = _watcher!.events.listen(_onEvent);
  }

  return initial;
}