1 write to Input
Microsoft.AspNetCore.Server.Kestrel.Core (1)
Internal\Http\Http1Connection.cs (1)
94
Input
= _context.Transport.Input;
21 references to Input
Microsoft.AspNetCore.Server.Kestrel.Core (21)
Internal\Http\Http1ChunkedEncodingMessageBody.cs (4)
100
var awaitable = _context.
Input
.ReadAsync();
149
_context.
Input
.AdvanceTo(consumed, examined);
152
awaitable = _context.
Input
.ReadAsync();
192
_context.
Input
.CancelPendingRead();
Internal\Http\Http1Connection.cs (4)
164
Input
.CancelPendingRead();
176
Input
.CancelPendingRead();
874
awaitable =
Input
.ReadAsync();
921
Input
.AdvanceTo(reader.Position, isConsumed ? reader.Position : result.Buffer.End);
Internal\Http\Http1ContentLengthMessageBody.cs (8)
60
var readAwaitable = _context.
Input
.ReadAsync(cancellationToken);
79
_context.
Input
.AdvanceTo(_readResult.Buffer.Start);
141
if (!_context.
Input
.TryRead(out _readResult))
152
_context.
Input
.AdvanceTo(_readResult.Buffer.Start);
163
_context.
Input
.AdvanceTo(_readResult.Buffer.Start);
224
_context.
Input
.AdvanceTo(consumed);
242
_context.
Input
.AdvanceTo(consumed, examined);
258
_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);
102
readResult = await _context.
Input
.ReadAsync(cancellationToken);