Class ProducerConsumerBackPressure

Simple back pressure implementation that makes sure the minimum max concurrency between producer and consumer is not amplified by the greedier of the two by more then the backPressureFactor which defaults to 4

Inheritance

object

ProducerConsumerBackPressure

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: OpenSearch.Client

Assembly: OpenSearch.Client.dll

Syntax

public class ProducerConsumerBackPressure

Methods

Release()

Declaration

public void Release()

WaitAsync(CancellationToken)

Declaration

public Task WaitAsync(CancellationToken token = default)

Parameters

Type	Name	Description
CancellationToken	token

Returns

Type	Description
Task

Extension Methods

SuffixExtensions.Suffix(object, string)