1 write to Pair
InMemory.FunctionalTests (1)
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (1)
505
Pair
= testStreamContext._pair;
21 references to Pair
InMemory.FunctionalTests (21)
Http3\Http3StreamTests.cs (13)
3048
Http3FrameWriter.WriteHeader(Http3FrameType.Settings, len, outboundcontrolStream.
Pair
.Application.Output);
3050
var parameterLength = VariableLengthIntegerHelper.WriteInteger(outboundcontrolStream.
Pair
.Application.Output.GetSpan(), (long)Internal.Http3.Http3SettingType.MaxFieldSectionSize);
3051
outboundcontrolStream.
Pair
.Application.Output.Advance(parameterLength);
3052
await outboundcontrolStream.
Pair
.Application.Output.FlushAsync();
3159
await WriteOneByteAtATime(bufferPipe.Reader, stream.
Pair
.Application.Output);
3165
await WriteOneByteAtATime(bufferPipe.Reader, stream.
Pair
.Application.Output);
3176
mem = stream.
Pair
.Application.Output.GetMemory();
3178
stream.
Pair
.Application.Output.Advance(1);
3181
await stream.
Pair
.Application.Output.FlushAsync();
3200
await WriteOneByteAtATime(bufferPipe.Reader, stream.
Pair
.Application.Output);
3244
await WriteOneByteAtATime(bufferPipe.Reader, outboundcontrolStream.
Pair
.Application.Output);
3266
await WriteOneByteAtATime(bufferPipe.Reader, outboundcontrolStream.
Pair
.Application.Output);
3277
await WriteOneByteAtATime(bufferPipe.Reader, outboundcontrolStream.
Pair
.Application.Output);
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (8)
510
var writableBuffer =
Pair
.Application.Output;
537
return
Pair
.Application.Input.ReadAsync().AsTask().DefaultTimeout();
598
Pair
.Application.Input.AdvanceTo(consumed, examined);
605
var outputWriter =
Pair
.Application.Output;
622
var writableBuffer =
Pair
.Application.Output;
726
var outputWriter =
Pair
.Application.Output;
869
var writableBuffer =
Pair
.Application.Output;
950
Pair
.Application.Input.AdvanceTo(consumed, examined);