Package com.mewna.catnip.rest.requester

Class AbstractRequester

java.lang.Object

com.mewna.catnip.rest.requester.AbstractRequester

All Implemented Interfaces:

Requester

Direct Known Subclasses:

BurstRequester, SerialRequester

public abstract class AbstractRequester
extends Object
implements Requester

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	AbstractRequester.Bucket
static class	AbstractRequester.QueuedRequest

Nested classes/interfaces inherited from interface com.mewna.catnip.rest.requester.Requester

Requester.OutboundRequest

Field Summary

Fields

Modifier and Type	Field	Description
protected Catnip	catnip
protected final RateLimiter	rateLimiter

Fields inherited from interface com.mewna.catnip.rest.requester.Requester

REASON_HEADER

Constructor Summary

Constructors

Constructor	Description
AbstractRequester(RateLimiter rateLimiter)

Method Summary

Modifier and Type	Method	Description
void	catnip(Catnip catnip)
protected void	executeHttpRequest(Routes.Route route, HttpRequest.BodyPublisher body, AbstractRequester.QueuedRequest request, String mediaType)
protected void	executeRequest(AbstractRequester.QueuedRequest request)
protected abstract AbstractRequester.Bucket	getBucket(Routes.Route route)
protected void	handleResponse(Routes.Route route, int statusCode, long requestEnd, String body, HttpHeaders headers, AbstractRequester.QueuedRequest request)
protected void	handleRouteBufferBodySend(Routes.Route finalRoute, AbstractRequester.QueuedRequest request)
protected void	handleRouteJsonBodySend(Routes.Route finalRoute, AbstractRequester.QueuedRequest request)
io.reactivex.rxjava3.core.Observable<ResponsePayload>	queue(Requester.OutboundRequest r)	Queues a new request to be executed.
protected void	updateBucket(Routes.Route route, HttpHeaders headers, long retryAfter, long timeDifference)

Methods inherited from class java.lang.Object

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

Field Details

rateLimiter

protected final RateLimiter rateLimiter

catnip

protected Catnip catnip

Constructor Details

AbstractRequester

public AbstractRequester(@Nonnull
 RateLimiter rateLimiter)

Method Details

catnip

public void catnip(@Nonnull
 Catnip catnip)

Specified by:

catnip in interface Requester

queue

@Nonnull
public io.reactivex.rxjava3.core.Observable<ResponsePayload> queue(@Nonnull
 Requester.OutboundRequest r)

Description copied from interface: Requester

Queues a new request to be executed.

Specified by:

queue in interface Requester

Parameters:

r - The request to execute.

Returns:

An Observable that emits when the request has completed.

getBucket

@Nonnull
@CheckReturnValue
protected abstract AbstractRequester.Bucket getBucket(@Nonnull
 Routes.Route route)

executeRequest

protected void executeRequest(@Nonnull
 AbstractRequester.QueuedRequest request)

handleRouteBufferBodySend

protected void handleRouteBufferBodySend(@Nonnull
 Routes.Route finalRoute,
 @Nonnull
 AbstractRequester.QueuedRequest request)

handleRouteJsonBodySend

protected void handleRouteJsonBodySend(@Nonnull
 Routes.Route finalRoute,
 @Nonnull
 AbstractRequester.QueuedRequest request)

executeHttpRequest

protected void executeHttpRequest(@Nonnull
 Routes.Route route,
 @Nullable
 HttpRequest.BodyPublisher body,
 @Nonnull
 AbstractRequester.QueuedRequest request,
 @Nonnull
 String mediaType)

handleResponse

protected void handleResponse(@Nonnull
 Routes.Route route,
 int statusCode,
 long requestEnd,
 String body,
 HttpHeaders headers,
 @Nonnull
 AbstractRequester.QueuedRequest request)

updateBucket

protected void updateBucket(@Nonnull
 Routes.Route route,
 @Nonnull
 HttpHeaders headers,
 long retryAfter,
 long timeDifference)