start method

@override Future<void> start()

Start the worker

Implementation

@override
Future<void> start() async {
  if (_isRunning) return;

  _isRunning = true;

  // Listen to responses from isolate
  _responseSubscription = _responsePort.listen((message) {
    if (message is Map<String, dynamic>) {
      final jobId = message['id'] as String?;
      if (jobId != null && _pendingJobs.containsKey(jobId)) {
        _pendingJobs[jobId]!.complete(message);
        _pendingJobs.remove(jobId);
      }
    }
  });
}