getWorkerHeartbeat method

  1. @override
Future<WorkerHeartbeat?> getWorkerHeartbeat(
  1. String workerId
)
override

Retrieves a worker heartbeat if still within its TTL.

Implementation

@override
/// Retrieves a worker heartbeat if still within its TTL.
Future<WorkerHeartbeat?> getWorkerHeartbeat(String workerId) async {
  final entry = _heartbeats[workerId];
  if (entry == null) return null;
  if (entry.expiresAt.isBefore(stemNow())) {
    _removeHeartbeat(workerId);
    return null;
  }
  return entry.heartbeat;
}