1 write to Input
Microsoft.AspNetCore.Server.Kestrel.Core (1)
Internal\Http\Http1Connection.cs (1)
68
Input
= _context.Transport.Input;
21 references to Input
Microsoft.AspNetCore.Server.Kestrel.Core (21)
Internal\Http\Http1ChunkedEncodingMessageBody.cs (4)
97
var awaitable = _context.
Input
.ReadAsync();
146
_context.
Input
.AdvanceTo(consumed, examined);
149
awaitable = _context.
Input
.ReadAsync();
189
_context.
Input
.CancelPendingRead();
Internal\Http\Http1Connection.cs (4)
138
Input
.CancelPendingRead();
150
Input
.CancelPendingRead();
710
awaitable =
Input
.ReadAsync();
741
Input
.AdvanceTo(reader.Position, isConsumed ? reader.Position : result.Buffer.End);
Internal\Http\Http1ContentLengthMessageBody.cs (8)
59
var readAwaitable = _context.
Input
.ReadAsync(cancellationToken);
78
_context.
Input
.AdvanceTo(_readResult.Buffer.Start);
140
if (!_context.
Input
.TryRead(out _readResult))
151
_context.
Input
.AdvanceTo(_readResult.Buffer.Start);
162
_context.
Input
.AdvanceTo(_readResult.Buffer.Start);
223
_context.
Input
.AdvanceTo(consumed);
241
_context.
Input
.AdvanceTo(consumed, examined);
257
_context.
Input
.CancelPendingRead();
Internal\Http\Http1UpgradeMessageBody.cs (5)
40
_context.
Input
.AdvanceTo(consumed, examined);
46
_context.
Input
.CancelPendingRead();
64
if (!_context.
Input
.TryRead(out readResult))
80
var readTask = _context.
Input
.ReadAsync(cancellationToken);
101
readResult = await _context.
Input
.ReadAsync(cancellationToken);