Limits the amount (count) of events passing the observable in the given time (slidingWindowTime).
Events exceeding the limit will be delayed until capacity is available again.
It uses token bucket algorithm. There are specified amount of tokens.
Once a value is emitted, it consumes a token. Tokens are regenerated after a the given time.
It allows for short bursts of values to go through.
When there are no tokens left, the value have to wait for a token to regenerate in order to be emitted.
Limits the amount (count) of events passing the observable in the given time (slidingWindowTime). Events exceeding the limit will be delayed until capacity is available again.
It uses token bucket algorithm. There are specified amount of tokens. Once a value is emitted, it consumes a token. Tokens are regenerated after a the given time. It allows for short bursts of values to go through. When there are no tokens left, the value have to wait for a token to regenerate in order to be emitted.