throttle<T> function

EventTransformer<T> throttle<T>(
  1. Duration duration
)

Throttles incoming events by the given duration.

Implementation

EventTransformer<T> throttle<T>(Duration duration) {
  return (events, mapper) {
    return events.throttleTime(duration).asyncExpand(mapper);
  };
}