process method

Implementation

@override
T process(T oldValue, T newValue) {
  final now = DateTime.now();
  if (_lastEmitTime != null) {
    final elapsed = now.difference(_lastEmitTime!);
    if (elapsed < minInterval) {
      return oldValue; // Reject new value
    }
  }
  _lastEmitTime = now;
  return newValue;
}