recordJobProcessed method

void recordJobProcessed(
  1. JobPriority priority,
  2. Duration processingTime
)

Implementation

void recordJobProcessed(JobPriority priority, Duration processingTime) {
  _processedByPriority[priority] = (_processedByPriority[priority] ?? 0) + 1;
  _totalProcessingTimeByPriority[priority] =
      (_totalProcessingTimeByPriority[priority] ?? Duration.zero) +
          processingTime;
}