ReadRequestBody

ReadRequestBody.cs

        public static async Task<string?> ReadBody(this HttpRequest httpRequest, Encoding? encoding = default)
        {
            encoding ??= Encoding.UTF8;

            // don't get it by `PipeReader.Create(httpContext.Request.Body);`
            var bodyReader = httpRequest.BodyReader;
            var context = httpRequest.HttpContext;

            ReadResult readResult;

            // read all the body without consuming it
            do
            {
                // read sequence of bytes from the pipe reader
                readResult = await bodyReader.ReadAsync(context.RequestAborted);

                // Tell the PipeReader how much of the buffer we have consumed
                bodyReader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End);

            } while (!readResult.IsCanceled && !readResult.IsCompleted);

            // now all the body payload has been read into buffer
            var buffer = readResult.Buffer;

            if (buffer.IsEmpty)
                return default;

            // process the buffer
            return encoding.GetString(buffer);
        }

        public static T? ReadBody<T>(this HttpRequest httpRequest)
        {
            // don't get it by `PipeReader.Create(httpContext.Request.Body);`
            var bodyReader = httpRequest.BodyReader;

            ReadResult readResult;

            // read all the body without consuming it
            do
            {
                // try to read sequence of bytes from the pipe reader
                if (!bodyReader.TryRead(out readResult))
                    continue;

                // Tell the PipeReader how much of the buffer we have consumed
                bodyReader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End);

            } while (!readResult.IsCanceled && !readResult.IsCompleted);

            // now all the body payload has been read into buffer
            var buffer = readResult.Buffer;

            if (buffer.IsEmpty)
                return default;

            // process the buffer
            var reader = new Utf8JsonReader(buffer);

            return JsonSerializer.Deserialize<T>(ref reader, JsonExtensions.JsonOptions);
        }