Class RateLimitingIterator<A>

java.lang.Object

com.jnape.palatable.lambda.internal.iteration.RateLimitingIterator<A>

All Implemented Interfaces:

Iterator<A>

public final class RateLimitingIterator<A>
extends Object
implements Iterator<A>

Field Summary

Fields

Modifier and Type	Field	Description
private final Iterator<A>	asIterator
private final Set<Tuple3<Long, Duration, Fn0<Instant>>>	rateLimits
private final Map<Tuple3<Long, Duration, Fn0<Instant>>, List<Instant>>	timeSlicesByRateLimit

Constructor Summary

Constructors

Constructor	Description
RateLimitingIterator(Iterator<A> asIterator, Set<Tuple3<Long, Duration, Fn0<Instant>>> rateLimits)

Method Summary

Modifier and Type	Method	Description
private void	awaitNextTimeSlice()
private void	awaitNextTimeSliceForRateLimit(Tuple3<Long, Duration, Fn0<Instant>> rateLimit)
boolean	hasNext()
A	next()
private boolean	rateLimitExhaustedInTimeSlice(Tuple3<Long, Duration, Fn0<Instant>> rateLimit)

Methods inherited from class Object

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

Methods inherited from interface Iterator

forEachRemaining, remove

Field Details

asIterator

private final Iterator<A> asIterator

rateLimits

private final Set<Tuple3<Long, Duration, Fn0<Instant>>> rateLimits

timeSlicesByRateLimit

private final Map<Tuple3<Long, Duration, Fn0<Instant>>, List<Instant>> timeSlicesByRateLimit

Constructor Details

RateLimitingIterator

public RateLimitingIterator(Iterator<A> asIterator,
 Set<Tuple3<Long, Duration, Fn0<Instant>>> rateLimits)

Method Details

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<A>

next

public A next()

Specified by:

next in interface Iterator<A>

awaitNextTimeSlice

private void awaitNextTimeSlice()

awaitNextTimeSliceForRateLimit

private void awaitNextTimeSliceForRateLimit(Tuple3<Long, Duration, Fn0<Instant>> rateLimit)

rateLimitExhaustedInTimeSlice

private boolean rateLimitExhaustedInTimeSlice(Tuple3<Long, Duration, Fn0<Instant>> rateLimit)