1 write to Input
Microsoft.AspNetCore.Server.Kestrel.Core (1)
Internal\Http\Http1Connection.cs (1)
98
Input
= _context.Transport.Input;
21 references to Input
Microsoft.AspNetCore.Server.Kestrel.Core (21)
Internal\Http\Http1ChunkedEncodingMessageBody.cs (4)
102
var awaitable = _context.
Input
.ReadAsync();
151
_context.
Input
.AdvanceTo(consumed, examined);
154
awaitable = _context.
Input
.ReadAsync();
194
_context.
Input
.CancelPendingRead();
Internal\Http\Http1Connection.cs (4)
168
Input
.CancelPendingRead();
180
Input
.CancelPendingRead();
904
awaitable =
Input
.ReadAsync();
951
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);