rxdart vanilla块中颤动去抖动api调用

import 'package:rxdart/rxdart.dart';

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

  final debounceStream = subject.debounce(Duration(milliseconds: 500));

  debounceStream.listen((data) {
    print('Debounced data: $data');
    // 在这里处理去抖动后的事件
  });

  // 模拟事件流，每隔200毫秒发送一个事件
  subject.add('Event 1');
  await Future.delayed(Duration(milliseconds: 200));
  subject.add('Event 2');
  await Future.delayed(Duration(milliseconds: 200));
  subject.add('Event 3');
  await Future.delayed(Duration(milliseconds: 200));
  subject.add('Event 4');
  await Future.delayed(Duration(milliseconds: 200));
  subject.add('Event 5');
  await Future.delayed(Duration(milliseconds: 200));
  subject.add('Event 6');
}