Table of Contents

Interface IDownStreamPipe

Namespace
Fluxzy.Core
Assembly
Fluxzy.Core.dll
public interface IDownStreamPipe : IDisposable
Inherited Members

Properties

CanWrite

bool CanWrite { get; }

Property Value

bool

RequestedAuthority

Authority RequestedAuthority { get; }

Property Value

Authority

SupportsMultiplexing

bool SupportsMultiplexing { get; }

Property Value

bool

TunnelOnly

bool TunnelOnly { get; }

Property Value

bool

Methods

AbandonPipe()

(Stream ReadStream, Stream WriteStream) AbandonPipe()

Returns

(Stream ReadStream, Stream WriteStream)

ReadNextExchange(RsBuffer, ExchangeScope, CancellationToken)

ValueTask<Exchange?> ReadNextExchange(RsBuffer buffer, ExchangeScope exchangeScope, CancellationToken token)

Parameters

buffer RsBuffer
exchangeScope ExchangeScope
token CancellationToken

Returns

ValueTask<Exchange>

WriteInterimResponse(int, ReadOnlyMemory<char>, int, CancellationToken)

Write an interim (1xx) response to the downstream client. Used to forward an upstream 100 Continue back to a client that sent Expect: 100-continue (issue #624).

ValueTask WriteInterimResponse(int statusCode, ReadOnlyMemory<char> reasonPhrase, int streamIdentifier, CancellationToken token)

Parameters

statusCode int
reasonPhrase ReadOnlyMemory<char>
streamIdentifier int
token CancellationToken

Returns

ValueTask

WriteResponseBody(Stream, RsBuffer, bool, int, Response?, CancellationToken)

ValueTask WriteResponseBody(Stream responseBodyStream, RsBuffer rsBuffer, bool chunked, int streamIdentifier, Response? responseForTrailers, CancellationToken token)

Parameters

responseBodyStream Stream
rsBuffer RsBuffer
chunked bool
streamIdentifier int
responseForTrailers Response
token CancellationToken

Returns

ValueTask

WriteResponseHeader(ResponseHeader, RsBuffer, bool, int, ReadOnlyMemory<char>, CancellationToken)

ValueTask WriteResponseHeader(ResponseHeader responseHeader, RsBuffer buffer, bool shouldClose, int streamIdentifier, ReadOnlyMemory<char> requestMethod, CancellationToken token)

Parameters

responseHeader ResponseHeader
buffer RsBuffer
shouldClose bool
streamIdentifier int
requestMethod ReadOnlyMemory<char>
token CancellationToken

Returns

ValueTask