15 overrides of AdvanceTo
InMemory.FunctionalTests (4)
Http3\WebTransport\WebTransportTestUtilities.cs (1)
170public override void AdvanceTo(SequencePosition consumed)
src\Servers\Kestrel\shared\CompletionPipeReader.cs (1)
23public override void AdvanceTo(SequencePosition consumed)
src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)
70public override void AdvanceTo(SequencePosition consumed) => _input.AdvanceTo(consumed);
TestTransport\InMemoryTransportConnection.cs (1)
127public override void AdvanceTo(SequencePosition consumed)
Microsoft.AspNetCore.Server.Kestrel.Core (1)
Internal\Http\HttpRequestPipeReader.cs (1)
24public override void AdvanceTo(SequencePosition consumed)
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (1)
src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)
70public override void AdvanceTo(SequencePosition consumed) => _input.AdvanceTo(consumed);
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (1)
src\Servers\Kestrel\shared\CompletionPipeReader.cs (1)
23public override void AdvanceTo(SequencePosition consumed)
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (1)
src\Servers\Kestrel\shared\CompletionPipeReader.cs (1)
23public override void AdvanceTo(SequencePosition consumed)
Microsoft.AspNetCore.SignalR.Microbenchmarks (1)
Shared\TestPipeReader.cs (1)
17public override void AdvanceTo(SequencePosition consumed)
Microsoft.AspNetCore.SignalR.Tests (1)
HubConnectionHandlerTests.cs (1)
2944public override void AdvanceTo(SequencePosition consumed) =>
Sockets.FunctionalTests (2)
src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)
70public override void AdvanceTo(SequencePosition consumed) => _input.AdvanceTo(consumed);
src\Servers\Kestrel\test\FunctionalTests\ConnectionMiddlewareTests.cs (1)
97public override void AdvanceTo(SequencePosition consumed)
System.IO.Pipelines (3)
System\IO\Pipelines\Pipe.DefaultPipeReader.cs (1)
28public override void AdvanceTo(SequencePosition consumed) => _pipe.AdvanceReader(consumed);
System\IO\Pipelines\SequencePipeReader.cs (1)
23public override void AdvanceTo(SequencePosition consumed)
System\IO\Pipelines\StreamPipeReader.cs (1)
69public override void AdvanceTo(SequencePosition consumed)
139 references to AdvanceTo
Aspire.Dashboard (1)
Otlp\Http\OtlpHttpEndpointsBuilder.cs (1)
215httpContext.Request.BodyReader.AdvanceTo(result.Buffer.End);
ClientSample (2)
RawSample.cs (1)
96input.AdvanceTo(buffer.End);
Tcp\TcpConnection.cs (1)
236_application.Input.AdvanceTo(end);
InMemory.FunctionalTests (19)
ChunkedRequestTests.cs (6)
53request.BodyReader.AdvanceTo(readResult.Buffer.End); 390request.BodyReader.AdvanceTo(result.Buffer.End); 919request.BodyReader.AdvanceTo(readResult.Buffer.End); 975request.BodyReader.AdvanceTo(readResult.Buffer.End); 1025request.BodyReader.AdvanceTo(readResult.Buffer.End); 1088request.BodyReader.AdvanceTo(readResult.Buffer.End);
Http2\Http2ConnectionTests.cs (1)
1401context.Request.BodyReader.AdvanceTo(readResult.Buffer.End);
Http2\Http2StreamTests.cs (3)
1006context.Request.BodyReader.AdvanceTo(readResult.Buffer.End); 1044context.Request.BodyReader.AdvanceTo(readResult.Buffer.End); 1289context.Request.BodyReader.AdvanceTo(readResult.Buffer.End);
Http3\Http3StreamTests.cs (1)
630context.Request.BodyReader.AdvanceTo(readResult.Buffer.End);
RequestTests.cs (5)
1020httpContext.Request.BodyReader.AdvanceTo(readResult.Buffer.End); 1911request.BodyReader.AdvanceTo(readResult.Buffer.End); 1961request.BodyReader.AdvanceTo(readResult.Buffer.End); 2003request.BodyReader.AdvanceTo(readResult.Buffer.End); 2046request.BodyReader.AdvanceTo(readResult.Buffer.End);
src\Servers\Kestrel\shared\CompletionPipeReader.cs (1)
25_inner.AdvanceTo(consumed);
src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)
70public override void AdvanceTo(SequencePosition consumed) => _input.AdvanceTo(consumed);
TestTransport\InMemoryTransportConnection.cs (1)
129_reader.AdvanceTo(consumed);
Interop.FunctionalTests (3)
HttpClientHttp2InteropTests.cs (3)
283reader.AdvanceTo(sequence.End); 340reader.AdvanceTo(sequence.End); 355reader.AdvanceTo(readResult.Buffer.End);
Microsoft.AspNetCore.Http.Connections (3)
Internal\Transports\LongPollingServerTransport.cs (1)
63_application.AdvanceTo(buffer.End);
Internal\Transports\ServerSentEventsServerTransport.cs (1)
76_application.AdvanceTo(buffer.End);
Internal\Transports\WebSocketsServerTransport.cs (1)
265_application.Input.AdvanceTo(buffer.End);
Microsoft.AspNetCore.Http.Connections.Client (2)
Internal\SendUtils.cs (1)
69application.Input.AdvanceTo(buffer.End);
Internal\WebSocketsTransport.cs (1)
585_application.Input.AdvanceTo(buffer.End);
Microsoft.AspNetCore.Http.Connections.Tests (14)
HttpConnectionDispatcherTests.cs (9)
246connection.Transport.Input.AdvanceTo(result.Buffer.End); 615connection.Transport.Input.AdvanceTo(result.Buffer.End); 3818connection.Transport.Input.AdvanceTo(result.Buffer.End); 3866connection.Transport.Input.AdvanceTo(result.Buffer.End); 3895connection.Transport.Input.AdvanceTo(result.Buffer.End); 3924connection.Transport.Input.AdvanceTo(result.Buffer.End); 3951connection.Transport.Input.AdvanceTo(result.Buffer.End); 3978connection.Transport.Input.AdvanceTo(result.Buffer.End); 4026connection.Transport.Input.AdvanceTo(res.Buffer.End);
HttpConnectionManagerTests.cs (2)
110connection.Transport.Input.AdvanceTo(result.Buffer.End); 259connection.Transport.Input.AdvanceTo(result.Buffer.End);
MapConnectionHandlerTests.cs (1)
444connection.Transport.Input.AdvanceTo(result.Buffer.Start);
WebSocketsTests.cs (2)
57connection.Transport.Input.AdvanceTo(buffer.End); 133connection.Transport.Input.AdvanceTo(result.Buffer.End);
Microsoft.AspNetCore.Http.Extensions.Tests (4)
RequestDelegateGenerator\RequestDelegateCreationTests.JsonBody.cs (4)
252httpContext.Request.BodyReader.AdvanceTo(result.Buffer.End); 293httpContext.Request.BodyReader.AdvanceTo(result.Buffer.End); 334httpContext.Request.BodyReader.AdvanceTo(result.Buffer.End); 375httpContext.Request.BodyReader.AdvanceTo(result.Buffer.End);
Microsoft.AspNetCore.Server.IIS (1)
Core\IISHttpContext.IO.cs (1)
206_bodyOutput.Reader.AdvanceTo(buffer.End);
Microsoft.AspNetCore.Server.Kestrel.Core (10)
Internal\Http\Http1ContentLengthMessageBody.cs (4)
78_context.Input.AdvanceTo(_readResult.Buffer.Start); 151_context.Input.AdvanceTo(_readResult.Buffer.Start); 162_context.Input.AdvanceTo(_readResult.Buffer.Start); 223_context.Input.AdvanceTo(consumed);
Internal\Http2\Http2Connection.cs (1)
1876reader.AdvanceTo(bufferSlice.End);
Internal\Http2\Http2FrameWriter.cs (1)
310reader.AdvanceTo(buffer.End);
Internal\Http3\Http3ControlStream.cs (1)
293Input.AdvanceTo(readableBuffer.End);
Internal\Http3\Http3OutputProducer.cs (1)
455_pipeReader.AdvanceTo(readResult.Buffer.End);
Internal\Http3\Http3PendingStream.cs (2)
90Input.AdvanceTo(consumed); 94Input.AdvanceTo(start);
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (21)
BodyControlTests.cs (2)
95Assert.Throws<Exception>(() => requestPipe.AdvanceTo(new SequencePosition()))); 115Assert.Throws<ObjectDisposedException>(() => requestPipe.AdvanceTo(new SequencePosition()));
BufferWriterTests.cs (1)
31Pipe.Reader.AdvanceTo(readResult.Buffer.End);
Http1\Http1ConnectionTests.cs (2)
131_transport.Input.AdvanceTo(TakeStartLineAndMessageHeaders()); 145_transport.Input.AdvanceTo(TakeMessageHeaders());
MessageBodyTests.cs (14)
73reader.AdvanceTo(readResult.Buffer.End); 77reader.AdvanceTo(readResult.Buffer.End); 100reader.AdvanceTo(readResult.Buffer.End); 104reader.AdvanceTo(readResult.Buffer.End); 1098reader.AdvanceTo(readResult.Buffer.End); 1104reader.AdvanceTo(readResult.Buffer.End); 1125reader.AdvanceTo(readResult.Buffer.End); 1150reader.AdvanceTo(readResult.Buffer.End); 1176reader.AdvanceTo(readResult.Buffer.End); 1201reader.AdvanceTo(readResult.Buffer.End); 1310reader.AdvanceTo(readResult.Buffer.End); 1334reader.AdvanceTo(readResult.Buffer.End); 1360reader.AdvanceTo(readResult.Buffer.End); 1386reader.AdvanceTo(readResult.Buffer.End);
PipelineExtensionTests.cs (1)
66_pipe.Reader.AdvanceTo(readResult.Buffer.End);
src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)
70public override void AdvanceTo(SequencePosition consumed) => _input.AdvanceTo(consumed);
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (3)
InMemoryTransportBenchmark.cs (1)
199Output.AdvanceTo(buffer.End);
RequestParsingBenchmark.cs (1)
166Pipe.Reader.AdvanceTo(readableBuffer.End);
src\Servers\Kestrel\shared\CompletionPipeReader.cs (1)
25_inner.AdvanceTo(consumed);
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (1)
Internal\NamedPipeConnection.cs (1)
178Output.AdvanceTo(buffer.End);
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (2)
Internal\QuicStreamContext.cs (1)
425output.AdvanceTo(end);
src\Servers\Kestrel\shared\CompletionPipeReader.cs (1)
25_inner.AdvanceTo(consumed);
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic.Tests (3)
QuicConnectionContextTests.cs (2)
111serverStream.Transport.Input.AdvanceTo(read.Buffer.End); 613serverStream.Transport.Input.AdvanceTo(readResult.Buffer.End);
QuicTestHelpers.cs (1)
156serverStream.Transport.Input.AdvanceTo(readResult.Buffer.End);
Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets (1)
Internal\SocketConnection.cs (1)
314Output.AdvanceTo(buffer.End);
Microsoft.AspNetCore.SignalR.Client.Tests (2)
TestConnection.cs (1)
167Application.Input.AdvanceTo(consumed);
TestTransport.cs (1)
73Application.Input.AdvanceTo(result.Buffer.End);
Microsoft.AspNetCore.SignalR.Microbenchmarks (1)
BroadcastBenchmark.cs (1)
83application.Input.AdvanceTo(buffer.End);
Microsoft.AspNetCore.SignalR.Specification.Tests (2)
src\SignalR\common\testassets\Tests.Utils\TestClient.cs (2)
265Connection.Application.Input.AdvanceTo(buffer.Start); 304Connection.Application.Input.AdvanceTo(buffer.Start);
Microsoft.AspNetCore.SignalR.Tests (30)
AuthConnectionHandler.cs (1)
30connection.Transport.Input.AdvanceTo(buffer.End);
EchoConnectionHandler.cs (1)
28connection.Transport.Input.AdvanceTo(buffer.End);
HttpHeaderConnectionHandler.cs (1)
34connection.Transport.Input.AdvanceTo(buffer.End);
HubConnectionHandlerTests.cs (1)
2945_originalPipeReader.AdvanceTo(consumed);
Internal\MessageBufferTests.cs (25)
40pipes.Application.Input.AdvanceTo(buffer.Start); 65pipes.Application.Input.AdvanceTo(buffer.Start); 79pipes.Application.Input.AdvanceTo(buffer.Start); 106pipes.Application.Input.AdvanceTo(buffer.Start); 115pipes.Application.Input.AdvanceTo(buffer.Start); 140pipes.Application.Input.AdvanceTo(buffer.Start); 156pipes.Application.Input.AdvanceTo(buffer.Start); 164pipes.Application.Input.AdvanceTo(buffer.Start); 189pipes.Application.Input.AdvanceTo(buffer.Start); 203pipes.Application.Input.AdvanceTo(buffer.Start); 213pipes.Application.Input.AdvanceTo(buffer.Start); 235pipes.Application.Input.AdvanceTo(buffer.Start); 267pipes.Application.Input.AdvanceTo(buffer.Start); 277pipes.Application.Input.AdvanceTo(buffer.Start); 303pipes.Application.Input.AdvanceTo(buffer.Start); 317pipes.Application.Input.AdvanceTo(buffer.Start); 347pipes.Application.Input.AdvanceTo(buffer.Start); 356pipes.Application.Input.AdvanceTo(buffer.Start); 382pipes.Application.Input.AdvanceTo(buffer.Start); 394pipes.Application.Input.AdvanceTo(buffer.Start); 426pipes.Application.Input.AdvanceTo(buffer.Start); 434pipes.Application.Input.AdvanceTo(buffer.Start); 473pipes.Application.Input.AdvanceTo(buffer.Start); 483pipes.Application.Input.AdvanceTo(buffer.Start); 492pipes.Application.Input.AdvanceTo(buffer.Start);
WriteThenCloseConnectionHandler.cs (1)
22connection.Transport.Input.AdvanceTo(buffer.End);
Microsoft.AspNetCore.SignalR.Tests.Utils (5)
PipeReaderExtensions.cs (3)
48pipeReader.AdvanceTo(result.Buffer.End); 64pipeReader.AdvanceTo(result.Buffer.GetPosition(numBytes)); 100pipeReader.AdvanceTo(buffer.End);
TestClient.cs (2)
265Connection.Application.Input.AdvanceTo(buffer.Start); 304Connection.Application.Input.AdvanceTo(buffer.Start);
Microsoft.AspNetCore.TestHost (1)
ResponseBodyReaderStream.cs (1)
105_pipe.Reader.AdvanceTo(readableBuffer.End);
Microsoft.AspNetCore.WebUtilities (1)
FormPipeReader.cs (1)
115_pipeReader.AdvanceTo(buffer.End);
SignalR.Client.FunctionalTestApp (1)
EchoConnectionHandler.cs (1)
31connection.Transport.Input.AdvanceTo(result.Buffer.End);
SignalRSamples (1)
ConnectionHandlers\MessagesConnectionHandler.cs (1)
46connection.Transport.Input.AdvanceTo(buffer.End);
SocialWeather (1)
SocialWeatherConnectionHandler.cs (1)
57connection.Transport.Input.AdvanceTo(buffer.End);
Sockets.FunctionalTests (2)
src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)
70public override void AdvanceTo(SequencePosition consumed) => _input.AdvanceTo(consumed);
src\Servers\Kestrel\test\FunctionalTests\UnixDomainSocketsTests.cs (1)
65connection.Transport.Input.AdvanceTo(result.Buffer.End);
System.IO.Pipelines (2)
System\IO\Pipelines\PipeReader.cs (1)
286AdvanceTo(consumed);
System\IO\Pipelines\PipeReaderStream.cs (1)
142_pipeReader.AdvanceTo(consumed);