RxDart based implementation of rate limit

rate_limit.dart

import 'dart:async';

import 'package:rxdart/rxdart.dart';

class StreamDebounce {
  final Function func;
  final Duration interval;

  final subject = PublishSubject<List<dynamic>>();
  StreamSubscription subscriber;

  StreamDebounce(this.func, this.interval) {
    subscriber = subject.stream
        .throttleTime(interval, trailing: true, leading: true)
        .listen((event) {
      Function.apply(func, event);
    });
  }

  void clean() {
    subscriber?.cancel();
    subject.close();
  }

  void call(List<dynamic> args) {
    subject.sink.add(args);
  }
}