Package io.servicetalk.client.api.internal

Class RequestConcurrencyControllers

java.lang.Object

io.servicetalk.client.api.internal.RequestConcurrencyControllers

@Deprecated
public final class RequestConcurrencyControllers
extends Object

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.

Factory for common RequestConcurrencyControllers.

Method Summary

Modifier and Type	Method	Description
static RequestConcurrencyController	newController(Publisher<? extends ConsumableEvent<Integer>> maxConcurrency, Completable onClosing, int initialMaxConcurrency)	Deprecated. Create a new instance of RequestConcurrencyController.
static RequestConcurrencyController	newSingleController(Publisher<? extends ConsumableEvent<Integer>> maxConcurrency, Completable onClosing)	Deprecated. 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 Details

newController

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

Deprecated.

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<Integer>> maxConcurrency,
 Completable onClosing)

Deprecated.

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.