AdvanceTo

Http3\WebTransport\WebTransportTestUtilities.cs (1)

175public override void AdvanceTo(SequencePosition consumed, SequencePosition examined)

src\Servers\Kestrel\shared\CompletionPipeReader.cs (1)

28public override void AdvanceTo(SequencePosition consumed, SequencePosition examined)

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)

72public override void AdvanceTo(SequencePosition consumed, SequencePosition examined) => _input.AdvanceTo(consumed, examined);

TestTransport\InMemoryTransportConnection.cs (1)

130public override void AdvanceTo(SequencePosition consumed, SequencePosition examined)

Internal\Http\HttpRequestPipeReader.cs (1)

31public override void AdvanceTo(SequencePosition consumed, SequencePosition examined)

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)

72public override void AdvanceTo(SequencePosition consumed, SequencePosition examined) => _input.AdvanceTo(consumed, examined);

TestHelpers\ObservablePipeReader.cs (1)

28public override void AdvanceTo(SequencePosition consumed, SequencePosition examined)

src\Servers\Kestrel\shared\CompletionPipeReader.cs (1)

28public override void AdvanceTo(SequencePosition consumed, SequencePosition examined)

src\Servers\Kestrel\shared\CompletionPipeReader.cs (1)

28public override void AdvanceTo(SequencePosition consumed, SequencePosition examined)

Shared\TestPipeReader.cs (1)

21public override void AdvanceTo(SequencePosition consumed, SequencePosition examined)

HubConnectionHandlerTests.cs (1)

2947public override void AdvanceTo(SequencePosition consumed, SequencePosition examined) =>

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)

72public override void AdvanceTo(SequencePosition consumed, SequencePosition examined) => _input.AdvanceTo(consumed, examined);

src\Servers\Kestrel\test\FunctionalTests\ConnectionMiddlewareTests.cs (1)

102public override void AdvanceTo(SequencePosition consumed, SequencePosition examined)

System\IO\Pipelines\Pipe.DefaultPipeReader.cs (1)

30public override void AdvanceTo(SequencePosition consumed, SequencePosition examined) => _pipe.AdvanceReader(consumed, examined);

System\IO\Pipelines\SequencePipeReader.cs (1)

29public override void AdvanceTo(SequencePosition consumed, SequencePosition examined)

System\IO\Pipelines\StreamPipeReader.cs (1)

85public override void AdvanceTo(SequencePosition consumed, SequencePosition examined)

Otlp\Http\OtlpHttpEndpointsBuilder.cs (1)

280httpContext.Request.BodyReader.AdvanceTo(result.Buffer.Start, result.Buffer.End);

Dcp\DcpHost.cs (1)

341reader.AdvanceTo(position, result.Buffer.End);

src\Shared\Http2cat\Http2Utilities.cs (1)

867_pair.Application.Input.AdvanceTo(consumed, examined);

src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

148_input.AdvanceTo(readableBuffer.End, readableBuffer.End);

src\Shared\Http2cat\Http2Utilities.cs (1)

867_pair.Application.Input.AdvanceTo(consumed, examined);

src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

148_input.AdvanceTo(readableBuffer.End, readableBuffer.End);

src\Shared\Http2cat\Http2Utilities.cs (1)

867_pair.Application.Input.AdvanceTo(consumed, examined);

src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

148_input.AdvanceTo(readableBuffer.End, readableBuffer.End);

src\Shared\Http2cat\Http2Utilities.cs (1)

867_pair.Application.Input.AdvanceTo(consumed, examined);

src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

148_input.AdvanceTo(readableBuffer.End, readableBuffer.End);

src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

148_input.AdvanceTo(readableBuffer.End, readableBuffer.End);

src\Shared\Http2cat\Http2Utilities.cs (1)

867_pair.Application.Input.AdvanceTo(consumed, examined);

src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

148_input.AdvanceTo(readableBuffer.End, readableBuffer.End);

Http2\Http2ConnectionTests.cs (3)

1414context.Request.BodyReader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End); 1418context.Request.BodyReader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End); 5691context.Request.BodyReader.AdvanceTo(result.Buffer.Start, result.Buffer.End);

Http2\Http2StreamTests.cs (2)

1001context.Request.BodyReader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End); 1284context.Request.BodyReader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End);

Http2\Http2TestBase.cs (2)

1222_pair.Application.Input.AdvanceTo(result.Buffer.Start, result.Buffer.End); 1261_pair.Application.Input.AdvanceTo(consumed, examined);

Http2\TlsTests.cs (1)

133reader.AdvanceTo(consumed, examined);

Http3\Http3StreamTests.cs (1)

627context.Request.BodyReader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End);

RequestTests.cs (10)

src\Servers\Kestrel\shared\CompletionPipeReader.cs (1)

30_inner.AdvanceTo(consumed, examined);

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (2)

616Pair.Application.Input.AdvanceTo(consumed, examined); 968Pair.Application.Input.AdvanceTo(consumed, examined);

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)

72public override void AdvanceTo(SequencePosition consumed, SequencePosition examined) => _input.AdvanceTo(consumed, examined);

TestTransport\InMemoryTransportConnection.cs (1)

132_reader.AdvanceTo(consumed, examined);

HttpClientHttp2InteropTests.cs (3)

276reader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End); 333reader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End); 349reader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End);

ServerStreamingServerCallHandlerTests.cs (2)

273pipeReader.AdvanceTo(end, end); 277pipeReader.AdvanceTo(buffer.Start, buffer.End);

CachedResponseBodyTests.cs (1)

111reader.AdvanceTo(buffer.End, buffer.End);

ResponseCachingBenchmark.cs (1)

101reader.AdvanceTo(buffer.End, buffer.End);

CachedResponseBodyTests.cs (1)

115reader.AdvanceTo(buffer.End, buffer.End);

src\Shared\Http2cat\Http2Utilities.cs (1)

867_pair.Application.Input.AdvanceTo(consumed, examined);

src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

148_input.AdvanceTo(readableBuffer.End, readableBuffer.End);

Core\IISHttpContext.IO.cs (1)

48_bodyInputPipe.Reader.AdvanceTo(readableBuffer.End, readableBuffer.End);

src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

148_input.AdvanceTo(readableBuffer.End, readableBuffer.End);

Internal\Http\Http1ChunkedEncodingMessageBody.cs (2)

42_requestBodyPipe.Reader.AdvanceTo(consumed, examined); 149_context.Input.AdvanceTo(consumed, examined);

Internal\Http\Http1Connection.cs (1)

866Input.AdvanceTo(reader.Position, isConsumed ? reader.Position : result.Buffer.End);

Internal\Http\Http1ContentLengthMessageBody.cs (1)

241_context.Input.AdvanceTo(consumed, examined);

Internal\Http\Http1UpgradeMessageBody.cs (1)

40_context.Input.AdvanceTo(consumed, examined);

Internal\Http2\Http2Connection.cs (2)

384Input.AdvanceTo(buffer.Start, buffer.End); 624Input.AdvanceTo(consumed, examined);

Internal\Http2\Http2MessageBody.cs (1)

71_context.RequestBodyPipe.Reader.AdvanceTo(consumed, examined);

Internal\Http3\Http3ControlStream.cs (2)

182Input.AdvanceTo(consumed, examined); 309Input.AdvanceTo(consumed, examined);

Internal\Http3\Http3MessageBody.cs (1)

46_context.RequestBodyPipe.Reader.AdvanceTo(consumed, examined);

Internal\Http3\Http3Stream.cs (1)

664Input.AdvanceTo(consumed, examined);

Middleware\TlsListener.cs (1)

67input.AdvanceTo(buffer.Start, buffer.End);

src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

148_input.AdvanceTo(readableBuffer.End, readableBuffer.End);

BodyControlTests.cs (2)

97Assert.Throws<Exception>(() => requestPipe.AdvanceTo(new SequencePosition(), new SequencePosition()))); 116Assert.Throws<ObjectDisposedException>(() => requestPipe.AdvanceTo(new SequencePosition(), new SequencePosition()));

Http1\Http1ConnectionTests.cs (16)

Http2\Http2FrameWriterTests.cs (1)

112pipeReader.AdvanceTo(buffer.Start, buffer.End);

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)

72public override void AdvanceTo(SequencePosition consumed, SequencePosition examined) => _input.AdvanceTo(consumed, examined);

TestHelpers\ObservablePipeReader.cs (1)

29=> _inner.AdvanceTo(consumed, examined);

ChunkWriterBenchmark.cs (1)

40_reader.AdvanceTo(result.Buffer.End, result.Buffer.End);

Http2\Http2ConnectionBenchmarkBase.cs (1)

180pipeReader.AdvanceTo(consumed, examined);

InMemoryTransportBenchmark.cs (1)

230Output.AdvanceTo(consumed, examined);

PipeThroughputBenchmark.cs (2)

46_pipe.Reader.AdvanceTo(result.Buffer.End, result.Buffer.End); 62_pipe.Reader.AdvanceTo(result.Buffer.End, result.Buffer.End);

RequestParsingBenchmark.cs (2)

190Pipe.Reader.AdvanceTo(reader.Position, reader.Position); 200Pipe.Reader.AdvanceTo(reader.Position, reader.Position);

src\Servers\Kestrel\shared\CompletionPipeReader.cs (1)

30_inner.AdvanceTo(consumed, examined);

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (2)

616Pair.Application.Input.AdvanceTo(consumed, examined); 968Pair.Application.Input.AdvanceTo(consumed, examined);

src\Servers\Kestrel\shared\CompletionPipeReader.cs (1)

30_inner.AdvanceTo(consumed, examined);

src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

148_input.AdvanceTo(readableBuffer.End, readableBuffer.End);

HubConnection.cs (2)

1561input.AdvanceTo(consumed, examined); 1700input.AdvanceTo(buffer.Start, buffer.End);

HubConnectionContext.cs (1)

628input.AdvanceTo(consumed, examined);

HubConnectionHandler.cs (1)

360input.AdvanceTo(buffer.Start, buffer.End);

HubConnectionHandlerTests.cs (1)

2948_originalPipeReader.AdvanceTo(consumed, examined);

PipeReaderExtensions.cs (4)

31pipeReader.AdvanceTo(result.Buffer.Start, result.Buffer.Start); 60pipeReader.AdvanceTo(result.Buffer.Start, result.Buffer.End); 81pipeReader.AdvanceTo(result.Buffer.Start, result.Buffer.End); 92pipeReader.AdvanceTo(result.Buffer.Start, result.Buffer.End);

FormPipeReader.cs (2)

108_pipeReader.AdvanceTo(buffer.Start, buffer.End); 124_pipeReader.AdvanceTo(buffer.Start, buffer.End);

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)

72public override void AdvanceTo(SequencePosition consumed, SequencePosition examined) => _input.AdvanceTo(consumed, examined);

System\IO\Pipelines\PipeReader.cs (3)

47/// Subsequent calls to <see cref="System.IO.Pipelines.PipeReader.AdvanceTo(System.SequencePosition,System.SequencePosition)" /> should 79AdvanceTo(buffer.Start, buffer.End); 87/// This is equivalent to calling <see cref="System.IO.Pipelines.PipeReader.AdvanceTo(System.SequencePosition,System.SequencePosition)" /> with identical examined and consumed positions.

System\Text\Json\Serialization\PipeReadBufferState.cs (1)

44_utf8Json.AdvanceTo(_sequence.Slice(bytesConsumed).Start, _sequence.End);