Package com.atlassian.confluence.util.misc

Class RateLimitedConsumer<T>

java.lang.Object

com.atlassian.confluence.util.misc.RateLimitedConsumer<T>

All Implemented Interfaces:

Consumer<T>

public class RateLimitedConsumer<T>
extends Object
implements Consumer<T>

Ignores calls to the wrapped consumer if the same key has been called within the minimum interval. Thread safe.

Since:

9.3

Constructor Summary

Constructors

Constructor	Description
RateLimitedConsumer(Consumer<T> callback, long minimumIntervalMs)	Creates a new rate limited consumer.

Method Summary

Modifier and Type	Method	Description
void	accept(T key)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.Consumer

andThen

Constructor Details

RateLimitedConsumer

public RateLimitedConsumer(Consumer<T> callback,
 long minimumIntervalMs)

Creates a new rate limited consumer.

Parameters:

callback - the consumer to call

minimumIntervalMs - the minimum interval between calls in milliseconds

Method Details

accept

public void accept(T key)

Specified by:

accept in interface Consumer<T>