Stream _throttle()

in lib/src/rate_limit.dart [123:134]

• 11 lines of code
• 2 McCabe index (conditional complexity)

  Stream<T> _throttle(Duration duration) {
    Timer? timer;

    return transformByHandlers(onData: (data, sink) {
      if (timer == null) {
        sink.add(data);
        timer = Timer(duration, () {
          timer = null;
        });
      }
    });
  }