Search Results for

    Show / Hide Table of Contents

    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

    | Edit this page View Source

    Release()

    Declaration
    public void Release()
    | Edit this page View Source

    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)
    • Edit this page
    • View Source
    In this article
    • Methods
      • Release()
      • WaitAsync(CancellationToken)
    • Extension Methods
    Back to top Generated by DocFX