Оператор throttle в библиотеке RxDart используется для ограничения частоты эмиссии событий из потока (Stream). Он пропускает первое событие, а затем игнорирует все последующие события в течение заданного интервала времени, после чего снова пропускает первое событие и так далее.

Это полезно, когда нужно предотвратить слишком частую обработку событий, например, при нажатии кнопки или вводе текста, чтобы не перегружать систему.

Пример использования:

import 'package:rxdart/rxdart.dart';

void main() {
  final subject = PublishSubject<int>();

  subject.throttleTime(Duration(seconds: 1)).listen((value) {
    print('Received: $value');
  });

  // Быстрая последовательность событий
  subject.add(1);
  subject.add(2);
  subject.add(3);

  // Через секунду
  Future.delayed(Duration(seconds: 2), () {
    subject.add(4);
  });
}

В этом примере из первых трёх быстрых событий будет обработано только первое, а событие с 4 будет обработано после задержки.

Можете объяснить, что делает оператор throttle в библиотеке RxDart и для чего его используют?