io.servicetalk.client.api.internal

Interface ReservableRequestConcurrencyController

All Superinterfaces:

RequestConcurrencyController

public interface ReservableRequestConcurrencyController
extends RequestConcurrencyController

A RequestConcurrencyController that also allows to tryReserve() a connection for exclusive use.

Nested Class Summary

Nested classes/interfaces inherited from interface io.servicetalk.client.api.internal.RequestConcurrencyController

RequestConcurrencyController.Result

Method Summary

Modifier and Type	Method and Description
Completable	releaseAsync() Must be called (and subscribed to) to signify the reservation has completed after tryReserve().
boolean	tryReserve() Attempts to reserve a connection for exclusive use until releaseAsync() is called.

Methods inherited from interface io.servicetalk.client.api.internal.RequestConcurrencyController

requestFinished, tryRequest

Method Detail

tryReserve

boolean tryReserve()

Attempts to reserve a connection for exclusive use until releaseAsync() is called.

Returns:

true if this connection is available and reserved for performing a single request.

releaseAsync

Completable releaseAsync()

Must be called (and subscribed to) to signify the reservation has completed after tryReserve().

Returns:

a Completable for the release.