16 references to Body
Microsoft.AspNetCore.Server.HttpSys (2)
RequestProcessing\RequestContext.cs (1)
110
var opaqueStream = new OpaqueStream(Request.
Body
, Response.Body);
RequestProcessing\RequestContext.FeatureCollection.cs (1)
163
_requestBody = Request.
Body
;
Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (14)
Listener\RequestBodyTests.cs (13)
31
Assert.Throws<InvalidOperationException>(() => context.Request.
Body
.Read(input, 0, input.Length));
36
var read = context.Request.
Body
.Read(input, 0, input.Length);
59
Task<int> task = context.Request.
Body
.ReadAsync(input, 0, input.Length, cts.Token);
81
int read = await context.Request.
Body
.ReadAsync(input, 0, input.Length, cts.Token);
84
read = await context.Request.
Body
.ReadAsync(input, 0, input.Length, cts.Token);
106
int read = await context.Request.
Body
.ReadAsync(input, 0, input.Length, cts.Token);
109
read = await context.Request.
Body
.ReadAsync(input, 0, input.Length, cts.Token);
130
int read = await context.Request.
Body
.ReadAsync(input, 0, input.Length, cts.Token);
132
var readTask = context.Request.
Body
.ReadAsync(input, 0, input.Length, cts.Token);
155
int read = await context.Request.
Body
.ReadAsync(input, 0, input.Length, cts.Token);
158
var readTask = context.Request.
Body
.ReadAsync(input, 0, input.Length, cts.Token);
182
int read = await context.Request.
Body
.ReadAsync(input, 0, input.Length, context.DisconnectToken);
185
var assertTask = Assert.ThrowsAsync<IOException>(async () => await context.Request.
Body
.ReadAsync(input, 0, input.Length, context.DisconnectToken));
Listener\ServerOnExistingQueueTests.cs (1)
61
string input = await new StreamReader(context.Request.
Body
).ReadToEndAsync();