discord4j.gateway

Class RateLimiterTransformer

java.lang.Object

discord4j.gateway.RateLimiterTransformer

All Implemented Interfaces:

PayloadTransformer, Function<Flux<ByteBuf>,Publisher<ByteBuf>>

public class RateLimiterTransformer
extends Object
implements PayloadTransformer

Transforms a payload sequence to throttle it using a RateLimiter instance.

Constructor Summary

Constructors

Constructor and Description
RateLimiterTransformer(RateLimiter limiter)

Method Summary

Modifier and Type	Method and Description
Publisher<ByteBuf>	apply(Flux<ByteBuf> publisher)

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.Function

andThen, compose, identity

Constructor Detail

RateLimiterTransformer

public RateLimiterTransformer(RateLimiter limiter)

Method Detail

apply

public Publisher<ByteBuf> apply(Flux<ByteBuf> publisher)

Specified by:

apply in interface Function<Flux<ByteBuf>,Publisher<ByteBuf>>