logLaneDequeue method

  1. @override
void logLaneDequeue(
  1. String lane, {
  2. Map<String, dynamic>? metadata,
})
override

Log a queue lane dequeue operation.

Implementation

@override
void logLaneDequeue(String lane, {Map<String, dynamic>? metadata}) {
  final state = _activities[lane];
  if (state != null && state.queueDepth > 0) {
    state.queueDepth--;
  }
  emit(DiagnosticEvent(
    type: 'queue.lane.dequeue',
    source: lane,
    timestamp: DateTime.now(),
    data: {'depth': state?.queueDepth ?? 0, ...?metadata},
  ));
}