throttleDroppable<E> static method

EventTransformer<E> throttleDroppable<E>(
  1. Duration duration
)

Implementation

static EventTransformer<E> throttleDroppable<E>(Duration duration) {
  return (Stream<E> events, Stream<E> Function(E) mapper) {
    return droppable<E>().call(events.throttle(duration), mapper);
  };
}