42 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)
142
_responseStream = new ResponseStream(Response.
Body
, OnResponseStart);
Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (40)
Listener\RequestBodyTests.cs (1)
38
context.Response.
Body
.Write(input, 0, read);
Listener\ResponseBodyTests.cs (35)
31
Assert.Throws<InvalidOperationException>(() => context.Response.
Body
.Flush());
32
Assert.Throws<InvalidOperationException>(() => context.Response.
Body
.Write(new byte[10], 0, 10));
33
Assert.Throws<InvalidOperationException>(() => context.Response.
Body
.Flush());
37
context.Response.
Body
.Flush();
38
context.Response.
Body
.Write(new byte[10], 0, 10);
39
context.Response.
Body
.Flush();
62
context.Response.
Body
.Write(new byte[10], 0, 10);
63
context.Response.
Body
.Flush();
64
await context.Response.
Body
.WriteAsync(new byte[10], 0, 10);
86
context.Response.
Body
.Write(new byte[10], 0, 0);
88
await context.Response.
Body
.WriteAsync(new byte[10], 0, 0);
112
await context.Response.
Body
.WriteAsync(new byte[10], 0, 10, cts.Token);
113
await context.Response.
Body
.WriteAsync(new byte[10], 0, 10, cts.Token);
134
await context.Response.
Body
.WriteAsync(new byte[10], 0, 10, cts.Token);
135
await context.Response.
Body
.WriteAsync(new byte[10], 0, 10, cts.Token);
157
var writeTask = context.Response.
Body
.WriteAsync(new byte[10], 0, 10, cts.Token);
177
var writeTask = context.Response.
Body
.WriteAsync(new byte[10], 0, 10, cts.Token);
197
await context.Response.
Body
.WriteAsync(new byte[10], 0, 10, cts.Token);
200
var writeTask = context.Response.
Body
.WriteAsync(new byte[10], 0, 10, cts.Token);
219
await context.Response.
Body
.WriteAsync(new byte[10], 0, 10, cts.Token);
222
var writeTask = context.Response.
Body
.WriteAsync(new byte[10], 0, 10, cts.Token);
256
context.Response.
Body
.Write(Utilities.WriteBuffer, 0, Utilities.WriteBuffer.Length);
261
Assert.Throws<ObjectDisposedException>(() => context.Response.
Body
.Write(Utilities.WriteBuffer, 0, Utilities.WriteBuffer.Length));
292
await context.Response.
Body
.WriteAsync(Utilities.WriteBuffer, 0, Utilities.WriteBuffer.Length);
297
await Assert.ThrowsAsync<ObjectDisposedException>(() => context.Response.
Body
.WriteAsync(Utilities.WriteBuffer, 0, Utilities.WriteBuffer.Length));
325
context.Response.
Body
.Write(Utilities.WriteBuffer, 0, Utilities.WriteBuffer.Length);
352
await context.Response.
Body
.WriteAsync(Utilities.WriteBuffer, 0, Utilities.WriteBuffer.Length);
377
context.Response.
Body
.Write(new byte[10], 0, 10);
390
context.Response.
Body
.Write(Utilities.WriteBuffer, 0, Utilities.WriteBuffer.Length);
416
await context.Response.
Body
.WriteAsync(new byte[10], 0, 10);
429
await context.Response.
Body
.WriteAsync(Utilities.WriteBuffer, 0, Utilities.WriteBuffer.Length);
455
context.Response.
Body
.Write(new byte[10], 0, 10);
466
context.Response.
Body
.Write(Utilities.WriteBuffer, 0, Utilities.WriteBuffer.Length);
489
await context.Response.
Body
.WriteAsync(new byte[10], 0, 10);
500
await context.Response.
Body
.WriteAsync(Utilities.WriteBuffer, 0, Utilities.WriteBuffer.Length);
Listener\ResponseHeaderTests.cs (1)
264
await context.Response.
Body
.WriteAsync(responseBytes, 0, responseBytes.Length);
Listener\ServerOnExistingQueueTests.cs (2)
43
await using (var writer = new StreamWriter(context.Response.
Body
))
64
await using (var writer = new StreamWriter(context.Response.
Body
))
Listener\ServerTests.cs (1)
101
var writer = new StreamWriter(context.Response.
Body
);