io.servicetalk.client.api.internal

Class ReservableRequestConcurrencyControllers

Object

ReservableRequestConcurrencyControllers

Deprecated.

This class is not used by ServiceTalk internal code anymore and will be removed in the future releases. If you depend on it, consider replicating this implementation in your codebase.

@Deprecated
public final class ReservableRequestConcurrencyControllers
extends Object

Factory for common ReservableRequestConcurrencyControllers.

Method Summary

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

Methods inherited from class Object

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

Method Detail

newController

public static ReservableRequestConcurrencyController newController(Publisher<? extends ConsumableEvent<Integer>> maxConcurrency,
                                                                   Completable onClosing,
                                                                   int initialMaxConcurrency)

Deprecated.

Create a new instance of ReservableRequestConcurrencyController.

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 ReservableRequestConcurrencyController.

newSingleController

public static ReservableRequestConcurrencyController newSingleController(Publisher<? extends ConsumableEvent<Integer>> maxConcurrency,
                                                                         Completable onClosing)

Deprecated.

Create a ReservableRequestConcurrencyController 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 ReservableRequestConcurrencyController that only allows a single outstanding request.