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)
2734
var outputWriter =
_pair
.Application.Output;
3755
Http2FrameWriter.WriteHeader(frame,
_pair
.Application.Output);
3756
await FlushAsync(
_pair
.Application.Output);
4312
_pair
.Application.Output.Complete();
4313
_pair
.Transport.Input.Complete();
4314
_pair
.Transport.Output.Complete();
4391
_pair
.Application.Output.Complete();
4392
_pair
.Transport.Input.Complete();
4393
_pair
.Transport.Output.Complete();
5100
_pair
.Application.Output.Complete(new ConnectionResetException(string.Empty));
5113
_pair
.Application.Output.Complete(new ConnectionResetException(string.Empty));
5129
var result = await
_pair
.Application.Input.ReadAsync().AsTask().DefaultTimeout();
5155
_pair
.Application.Output.Complete();
5183
_pair
.Application.Output.Complete();
5191
var readTask =
_pair
.Application.Input.ReadAsync();
5192
_pair
.Application.Input.CancelPendingRead();
5201
readTask =
_pair
.Application.Input.ReadAsync();
5202
_pair
.Application.Input.CancelPendingRead();
5306
var result = await
_pair
.Application.Input.ReadAsync().AsTask().DefaultTimeout();
5319
_pair
.Application.Output.Complete(ioException);
5339
_pair
.Application.Output.Complete(exception);
5520
_pair
.Transport.Input.Complete();
5521
_pair
.Transport.Output.Complete();
5602
_pair
.Transport.Input.Complete();
5603
_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);