io.servicetalk.client.api.internal

Class RequestConcurrencyControllers

java.lang.Object

io.servicetalk.client.api.internal.RequestConcurrencyControllers

public final class RequestConcurrencyControllers
extends java.lang.Object

Factory for common RequestConcurrencyControllers.

Method Summary

Modifier and Type	Method and Description
static RequestConcurrencyController	newController(Publisher<? extends ConsumableEvent<java.lang.Integer>> maxConcurrency, Completable onClosing, int initialMaxConcurrency) Create a new instance of RequestConcurrencyController.
static RequestConcurrencyController	newSingleController(Publisher<? extends ConsumableEvent<java.lang.Integer>> maxConcurrency, Completable onClosing) Create a RequestConcurrencyController that only allows a single outstanding request.

Methods inherited from class java.lang.Object

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

Method Detail

newController

public static RequestConcurrencyController newController(Publisher<? extends ConsumableEvent<java.lang.Integer>> maxConcurrency,
                                                         Completable onClosing,
                                                         int initialMaxConcurrency)

Create a new instance of RequestConcurrencyController.

Parameters:

maxConcurrency - A Publisher that provides the maximum allowed concurrency updates.

onClosing - A Completable that when terminated no more calls to RequestConcurrencyController.tryRequest() are expected to succeed.

initialMaxConcurrency - The initial maximum value for concurrency, until maxConcurrencySetting provides data.

Returns:

a new instance of RequestConcurrencyController.

newSingleController

public static RequestConcurrencyController newSingleController(Publisher<? extends ConsumableEvent<java.lang.Integer>> maxConcurrency,
                                                               Completable onClosing)

Create a RequestConcurrencyController that only allows a single outstanding request. Even if maxConcurrencySetting increases beyond 1 only a single RequestConcurrencyController.tryRequest() will succeed at any given time. The initial value is assumed to be 1 and only lesser values from maxConcurrencySetting will impact behavior.

Parameters:

maxConcurrency - A Publisher that provides the maximum allowed concurrency updates. Only values of <1 will impact behavior.

onClosing - A Completable that when terminated no more calls to RequestConcurrencyController.tryRequest() are expected to succeed.

Returns:

a RequestConcurrencyController that only allows a single outstanding request.