Package com.aitusoftware.aether.aggregation

Class StreamRate

java.lang.Object

com.aitusoftware.aether.aggregation.StreamRate

public final class StreamRate
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
StreamRate(java.util.List<RateBucket> rateBuckets)

Method Summary

Modifier and Type	Method	Description
void	consumeRates(RateConsumer rateConsumer)
void	streamPosition(long epochMillis, long position)

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamRate

public StreamRate(java.util.List<RateBucket> rateBuckets)

Method Detail

streamPosition

public void streamPosition(long epochMillis,
                           long position)

consumeRates

public void consumeRates(RateConsumer rateConsumer)