1 write to _pair
InMemory.FunctionalTests (1)
Http2\Http2TestBase.cs (1)
474
_pair
= DuplexPipe.CreateConnectionPair(inputPipeOptions, outputPipeOptions);
79 references to _pair
InMemory.FunctionalTests (79)
Http2\Http2ConnectionTests.cs (25)
2742
var outputWriter =
_pair
.Application.Output;
3774
Http2FrameWriter.WriteHeader(frame,
_pair
.Application.Output);
3775
await FlushAsync(
_pair
.Application.Output);
4331
_pair
.Application.Output.Complete();
4332
_pair
.Transport.Input.Complete();
4333
_pair
.Transport.Output.Complete();
4410
_pair
.Application.Output.Complete();
4411
_pair
.Transport.Input.Complete();
4412
_pair
.Transport.Output.Complete();
5119
_pair
.Application.Output.Complete(new ConnectionResetException(string.Empty));
5132
_pair
.Application.Output.Complete(new ConnectionResetException(string.Empty));
5148
var result = await
_pair
.Application.Input.ReadAsync().AsTask().DefaultTimeout();
5174
_pair
.Application.Output.Complete();
5202
_pair
.Application.Output.Complete();
5210
var readTask =
_pair
.Application.Input.ReadAsync();
5211
_pair
.Application.Input.CancelPendingRead();
5220
readTask =
_pair
.Application.Input.ReadAsync();
5221
_pair
.Application.Input.CancelPendingRead();
5325
var result = await
_pair
.Application.Input.ReadAsync().AsTask().DefaultTimeout();
5338
_pair
.Application.Output.Complete(ioException);
5358
_pair
.Application.Output.Complete(exception);
5539
_pair
.Transport.Input.Complete();
5540
_pair
.Transport.Output.Complete();
5621
_pair
.Transport.Input.Complete();
5622
_pair
.Transport.Output.Complete();
Http2\Http2TestBase.cs (51)
182
_pair
.Application.Output.Complete(ex);
419
_pair
.Application?.Input.Complete();
420
_pair
.Application?.Output.Complete();
421
_pair
.Transport?.Input.Complete();
422
_pair
.Transport?.Output.Complete();
488
transport:
_pair
.Transport,
565
_pair
.Transport.Input.Complete();
566
_pair
.Transport.Output.Complete();
616
var writableBuffer =
_pair
.Application.Output;
631
var writableBuffer =
_pair
.Application.Output;
650
var writableBuffer =
_pair
.Application.Output;
692
var writableBuffer =
_pair
.Application.Output;
737
var writableBuffer =
_pair
.Application.Output;
783
var writableBuffer =
_pair
.Application.Output;
797
_pair
.Application.Output.WriteSettings(_clientSettings);
798
await FlushAsync(
_pair
.Application.Output);
803
var writableBuffer =
_pair
.Application.Output;
813
var writableBuffer =
_pair
.Application.Output;
827
var writableBuffer =
_pair
.Application.Output;
839
var writableBuffer =
_pair
.Application.Output;
857
var writableBuffer =
_pair
.Application.Output;
869
var outputWriter =
_pair
.Application.Output;
890
var outputWriter =
_pair
.Application.Output;
904
var outputWriter =
_pair
.Application.Output;
921
var outputWriter =
_pair
.Application.Output;
939
var outputWriter =
_pair
.Application.Output;
955
var outputWriter =
_pair
.Application.Output;
967
var outputWriter =
_pair
.Application.Output;
994
var outputWriter =
_pair
.Application.Output;
1006
var outputWriter =
_pair
.Application.Output;
1024
var outputWriter =
_pair
.Application.Output;
1035
var outputWriter =
_pair
.Application.Output;
1057
var outputWriter =
_pair
.Application.Output;
1075
var outputWriter =
_pair
.Application.Output;
1084
var outputWriter =
_pair
.Application.Output;
1096
var outputWriter =
_pair
.Application.Output;
1113
var outputWriter =
_pair
.Application.Output;
1127
var outputWriter =
_pair
.Application.Output;
1143
var outputWriter =
_pair
.Application.Output;
1155
var outputWriter =
_pair
.Application.Output;
1165
var outputWriter =
_pair
.Application.Output;
1174
var outputWriter =
_pair
.Application.Output;
1184
var outputWriter =
_pair
.Application.Output;
1191
var outputWriter =
_pair
.Application.Output;
1201
var outputWriter =
_pair
.Application.Output;
1214
var result = await
_pair
.Application.Input.ReadAsync().AsTask().DefaultTimeout();
1222
_pair
.Application.Input.AdvanceTo(result.Buffer.Start, result.Buffer.End);
1232
var result = await
_pair
.Application.Input.ReadAsync().AsTask().DefaultTimeout();
1261
_pair
.Application.Input.AdvanceTo(consumed, examined);
1280
_pair
.Application.Output.Complete();
1304
_pair
.Application.Output.Complete();
Http2\Http2TimeoutTests.cs (3)
322
_pair
.Application.Output.Complete();
390
Assert.True((await
_pair
.Application.Input.ReadAsync().AsTask().DefaultTimeout()).IsCompleted);
445
Assert.True((await
_pair
.Application.Input.ReadAsync().AsTask().DefaultTimeout()).IsCompleted);