Class H2ConnectionPool

Namespace

Fluxzy.Clients.H2

Assembly

Fluxzy.Core.dll

public class H2ConnectionPool : IHttpConnectionPool, IAsyncDisposable

Inheritance

object

H2ConnectionPool

Implements

IHttpConnectionPool

IAsyncDisposable

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

H2ConnectionPool(Stream, H2StreamSetting, Authority, Connection, Action<H2ConnectionPool>, ILogger?)

public H2ConnectionPool(Stream baseStream, H2StreamSetting setting, Authority authority, Connection connection, Action<H2ConnectionPool> onConnectionFaulted, ILogger? logger = null)

Parameters

baseStream Stream

setting H2StreamSetting

authority Authority

connection Connection

onConnectionFaulted Action<H2ConnectionPool>

logger ILogger

Fields

IsDisposed

public volatile bool IsDisposed

Field Value

bool

TotalRequest

public volatile int TotalRequest

Field Value

int

Properties

Authority

public Authority Authority { get; }

Property Value

Authority

Complete

True once the pool is no longer accepting new exchanges — either because the connection has terminated (Fluxzy.Clients.H2.H2ConnectionPool._complete) or the remote sent GOAWAY and the pool is draining in-flight streams (Fluxzy.Clients.H2.StreamPool.IsDraining). Fluxzy.Clients.PoolBuilder uses this to route future exchanges to a fresh pool while existing in-flight streams continue to completion on this pool.

public bool Complete { get; }

Property Value

bool

Id

public int Id { get; }

Property Value

int

Setting

public H2StreamSetting Setting { get; }

Property Value

H2StreamSetting

Methods

DisposeAsync()

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources asynchronously.

public ValueTask DisposeAsync()

Returns

ValueTask

A task that represents the asynchronous dispose operation.

Init()

public void Init()

Send(Exchange, IDownStreamPipe, RsBuffer, ExchangeScope, CancellationToken)

public ValueTask Send(Exchange exchange, IDownStreamPipe _, RsBuffer buffer, ExchangeScope __, CancellationToken cancellationToken = default)

Parameters

exchange Exchange

_ IDownStreamPipe

buffer RsBuffer

__ ExchangeScope

cancellationToken CancellationToken

Returns

ValueTask