WriteRequestContentAsync()

async ValueTask System.Net.Http.Http3RequestStream.WriteRequestContentAsync ( ReadOnlyMemory< byte > buffer, CancellationToken cancellationToken )

inlineprivate

Definition at line 446 of file Http3RequestStream.cs.

    {
        if (buffer.Length == 0)
        {
            return;
        }
        long requestContentLengthRemaining = _requestContentLengthRemaining;
        if (requestContentLengthRemaining != -1)
        {
            if (buffer.Length > _requestContentLengthRemaining)
            {
                string net_http_content_write_larger_than_content_length = System.SR.net_http_content_write_larger_than_content_length;
                throw new IOException(net_http_content_write_larger_than_content_length, new HttpRequestException(net_http_content_write_larger_than_content_length));
            }
            _requestContentLengthRemaining -= buffer.Length;
            if (!_singleDataFrameWritten)
            {
                BufferFrameEnvelope(Http3FrameType.Data, requestContentLengthRemaining);
                _gatheredSendBuffer[0] = _sendBuffer.ActiveMemory;
                _gatheredSendBuffer[1] = buffer;
                await _stream.WriteAsync(_gatheredSendBuffer, cancellationToken).ConfigureAwait(continueOnCapturedContext: false);
                _sendBuffer.Discard(_sendBuffer.ActiveLength);
                _singleDataFrameWritten = true;
            }
            else
            {
                await _stream.WriteAsync(buffer, cancellationToken).ConfigureAwait(continueOnCapturedContext: false);
            }
        }
        else
        {
            BufferFrameEnvelope(Http3FrameType.Data, buffer.Length);
            _gatheredSendBuffer[0] = _sendBuffer.ActiveMemory;
            _gatheredSendBuffer[1] = buffer;
            await _stream.WriteAsync(_gatheredSendBuffer, cancellationToken).ConfigureAwait(continueOnCapturedContext: false);
            _sendBuffer.Discard(_sendBuffer.ActiveLength);
        }
    }

References System.Net.Http.Http3RequestStream._gatheredSendBuffer, System.Net.Http.Http3RequestStream._requestContentLengthRemaining, System.Net.Http.Http3RequestStream._sendBuffer, System.Net.Http.Http3RequestStream._singleDataFrameWritten, System.Net.Http.Http3RequestStream._stream, System.buffer, System.Net.Http.Http3RequestStream.BufferFrameEnvelope(), System.cancellationToken, System.SR.net_http_content_write_larger_than_content_length, and System.Net.Quic.QuicStream.WriteAsync().

Referenced by System.Net.Http.Http3RequestStream.Http3WriteStream.WriteAsync().