Môžete vysvetliť, čo robí operátor throttle v knižnici RxDart a na čo sa používa?

Operátor throttle v knižnici RxDart sa používá na obmedzenie frekvencie vysielania udalostí z prúdu (Stream). Prechádza prvou udalosťou a potom ignoruje všetky nasledujúce udalosti počas stanoveného časového intervalu, po ktorom opäť prechádza prvou udalosťou a tak ďalej.

To je užitočné, keď chcete zabrániť spracovaniu udalostí príliš často, napríklad pri kliknutí na tlačidlo alebo zadávaní textu, aby ste nezaťažovali systém.

Príklad použitia:

import 'package:rxdart/rxdart.dart';

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

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

  // Rýchla sekvencia udalostí
  subject.add(1);
  subject.add(2);
  subject.add(3);

  // Po sekunde
  Future.delayed(Duration(seconds: 2), () {
    subject.add(4);
  });
}

V tomto príklade bude spracovaná iba prvá z troch rýchlych udalostí, a udalosť s hodnotou 4 bude spracovaná po oneskorení.