Pair

1 write to Pair

InMemory.FunctionalTests (1)

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

506Pair = testStreamContext._pair;

21 references to Pair

InMemory.FunctionalTests (21)

Http3\Http3StreamTests.cs (13)

3048Http3FrameWriter.WriteHeader(Http3FrameType.Settings, len, outboundcontrolStream.Pair.Application.Output); 3050var parameterLength = VariableLengthIntegerHelper.WriteInteger(outboundcontrolStream.Pair.Application.Output.GetSpan(), (long)Internal.Http3.Http3SettingType.MaxFieldSectionSize); 3051outboundcontrolStream.Pair.Application.Output.Advance(parameterLength); 3052await outboundcontrolStream.Pair.Application.Output.FlushAsync(); 3159await WriteOneByteAtATime(bufferPipe.Reader, stream.Pair.Application.Output); 3165await WriteOneByteAtATime(bufferPipe.Reader, stream.Pair.Application.Output); 3176mem = stream.Pair.Application.Output.GetMemory(); 3178stream.Pair.Application.Output.Advance(1); 3181await stream.Pair.Application.Output.FlushAsync(); 3200await WriteOneByteAtATime(bufferPipe.Reader, stream.Pair.Application.Output); 3244await WriteOneByteAtATime(bufferPipe.Reader, outboundcontrolStream.Pair.Application.Output); 3266await WriteOneByteAtATime(bufferPipe.Reader, outboundcontrolStream.Pair.Application.Output); 3277await WriteOneByteAtATime(bufferPipe.Reader, outboundcontrolStream.Pair.Application.Output);

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

511var writableBuffer = Pair.Application.Output; 538return Pair.Application.Input.ReadAsync().AsTask().DefaultTimeout(); 599Pair.Application.Input.AdvanceTo(consumed, examined); 606var outputWriter = Pair.Application.Output; 623var writableBuffer = Pair.Application.Output; 727var outputWriter = Pair.Application.Output; 870var writableBuffer = Pair.Application.Output; 951Pair.Application.Input.AdvanceTo(consumed, examined);