Package com.flagsmith.threads

Class RequestProcessor

java.lang.Object

com.flagsmith.threads.RequestProcessor

public class RequestProcessor
extends Object

Constructor Summary

Constructors

Constructor	Description
RequestProcessor(okhttp3.OkHttpClient client, FlagsmithLogger logger)
RequestProcessor(okhttp3.OkHttpClient client, FlagsmithLogger logger, Retry retries)	Instantiate with client, logger and retries.

Method Summary

Modifier and Type	Method	Description
void	close()
<T> Future<T>	executeAsync(okhttp3.Request request, com.fasterxml.jackson.core.type.TypeReference<T> clazz, Boolean doThrow)	Execute the request in async mode.
<T> Future<T>	executeAsync(okhttp3.Request request, com.fasterxml.jackson.core.type.TypeReference<T> clazz, Boolean doThrow, Retry retries)	Execute the response in async mode.
Future<com.fasterxml.jackson.databind.JsonNode>	executeAsync(okhttp3.Request request, Boolean doThrow)	Execute the response in async mode and do not unmarshall.

Methods inherited from class java.lang.Object

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

Constructor Detail

RequestProcessor

public RequestProcessor(okhttp3.OkHttpClient client,
                        FlagsmithLogger logger)

RequestProcessor

public RequestProcessor(okhttp3.OkHttpClient client,
                        FlagsmithLogger logger,
                        Retry retries)

Instantiate with client, logger and retries.

Parameters:

client - client instance

logger - logger instance

retries - retries

Method Detail

executeAsync

public <T> Future<T> executeAsync(okhttp3.Request request,
                                  com.fasterxml.jackson.core.type.TypeReference<T> clazz,
                                  Boolean doThrow)

Execute the request in async mode.

Type Parameters:

T - Type inference for the response

Parameters:

request - request to invoke

clazz - class type of response

doThrow - should throw Exception (boolean)

Returns:

executeAsync

public Future<com.fasterxml.jackson.databind.JsonNode> executeAsync(okhttp3.Request request,
                                                                    Boolean doThrow)

Execute the response in async mode and do not unmarshall.

Parameters:

request - request to invoke

doThrow - whether to throw exception or not

Returns:

executeAsync

public <T> Future<T> executeAsync(okhttp3.Request request,
                                  com.fasterxml.jackson.core.type.TypeReference<T> clazz,
                                  Boolean doThrow,
                                  Retry retries)

Execute the response in async mode.

Type Parameters:

T - Type inference for the response

Parameters:

request - Request object

clazz - class type of response

doThrow - should throw Exception

retries - no of retries before failing

Returns:

close

public void close()