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)
2718
var outputWriter =
_pair
.Application.Output;
3739
Http2FrameWriter.WriteHeader(frame,
_pair
.Application.Output);
3740
await FlushAsync(
_pair
.Application.Output);
4296
_pair
.Application.Output.Complete();
4297
_pair
.Transport.Input.Complete();
4298
_pair
.Transport.Output.Complete();
4375
_pair
.Application.Output.Complete();
4376
_pair
.Transport.Input.Complete();
4377
_pair
.Transport.Output.Complete();
5084
_pair
.Application.Output.Complete(new ConnectionResetException(string.Empty));
5097
_pair
.Application.Output.Complete(new ConnectionResetException(string.Empty));
5113
var result = await
_pair
.Application.Input.ReadAsync().AsTask().DefaultTimeout();
5139
_pair
.Application.Output.Complete();
5167
_pair
.Application.Output.Complete();
5175
var readTask =
_pair
.Application.Input.ReadAsync();
5176
_pair
.Application.Input.CancelPendingRead();
5185
readTask =
_pair
.Application.Input.ReadAsync();
5186
_pair
.Application.Input.CancelPendingRead();
5289
var result = await
_pair
.Application.Input.ReadAsync().AsTask().DefaultTimeout();
5302
_pair
.Application.Output.Complete(ioException);
5322
_pair
.Application.Output.Complete(exception);
5503
_pair
.Transport.Input.Complete();
5504
_pair
.Transport.Output.Complete();
5585
_pair
.Transport.Input.Complete();
5586
_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);