Package io.servicetalk.client.api

Interface RequestConcurrencyController

All Known Subinterfaces:

FilterableStreamingHttpLoadBalancedConnection, LoadBalancedConnection, ReservableRequestConcurrencyController

All Known Implementing Classes:

DelegatingFilterableStreamingHttpLoadBalancedConnection, HttpLoadBalancerFactory.DefaultFilterableStreamingHttpLoadBalancedConnection

public interface RequestConcurrencyController

An interface which allows controlling reserving connections which maybe used concurrently.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static enum	RequestConcurrencyController.Result	Result of the tryRequest() call.

Method Summary

Modifier and Type	Method	Description
void	requestFinished()	Must be called after tryRequest() to signify the request has completed.
RequestConcurrencyController.Result	tryRequest()	Attempts to reserve a connection for a single request, needs to be followed by requestFinished().

Method Details

tryRequest

RequestConcurrencyController.Result tryRequest()

Attempts to reserve a connection for a single request, needs to be followed by requestFinished().

Returns:

RequestConcurrencyController.Result.Accepted if this connection is available and reserved for performing a single request.

requestFinished

void requestFinished()

Must be called after tryRequest() to signify the request has completed. This method should be called no more than once for each call to tryRequest().

Generally called from a Publisher.beforeFinally(Runnable) after a tryRequest().