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)
2734var outputWriter = _pair.Application.Output; 3755Http2FrameWriter.WriteHeader(frame, _pair.Application.Output); 3756await 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)); 5129var result = await _pair.Application.Input.ReadAsync().AsTask().DefaultTimeout(); 5155_pair.Application.Output.Complete(); 5183_pair.Application.Output.Complete(); 5191var readTask = _pair.Application.Input.ReadAsync(); 5192_pair.Application.Input.CancelPendingRead(); 5201readTask = _pair.Application.Input.ReadAsync(); 5202_pair.Application.Input.CancelPendingRead(); 5306var 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(); 488transport: _pair.Transport, 565_pair.Transport.Input.Complete(); 566_pair.Transport.Output.Complete(); 616var writableBuffer = _pair.Application.Output; 631var writableBuffer = _pair.Application.Output; 650var writableBuffer = _pair.Application.Output; 692var writableBuffer = _pair.Application.Output; 737var writableBuffer = _pair.Application.Output; 783var writableBuffer = _pair.Application.Output; 797_pair.Application.Output.WriteSettings(_clientSettings); 798await FlushAsync(_pair.Application.Output); 803var writableBuffer = _pair.Application.Output; 813var writableBuffer = _pair.Application.Output; 827var writableBuffer = _pair.Application.Output; 839var writableBuffer = _pair.Application.Output; 857var writableBuffer = _pair.Application.Output; 869var outputWriter = _pair.Application.Output; 890var outputWriter = _pair.Application.Output; 904var outputWriter = _pair.Application.Output; 921var outputWriter = _pair.Application.Output; 939var outputWriter = _pair.Application.Output; 955var outputWriter = _pair.Application.Output; 967var outputWriter = _pair.Application.Output; 994var outputWriter = _pair.Application.Output; 1006var outputWriter = _pair.Application.Output; 1024var outputWriter = _pair.Application.Output; 1035var outputWriter = _pair.Application.Output; 1057var outputWriter = _pair.Application.Output; 1075var outputWriter = _pair.Application.Output; 1084var outputWriter = _pair.Application.Output; 1096var outputWriter = _pair.Application.Output; 1113var outputWriter = _pair.Application.Output; 1127var outputWriter = _pair.Application.Output; 1143var outputWriter = _pair.Application.Output; 1155var outputWriter = _pair.Application.Output; 1165var outputWriter = _pair.Application.Output; 1174var outputWriter = _pair.Application.Output; 1184var outputWriter = _pair.Application.Output; 1191var outputWriter = _pair.Application.Output; 1201var outputWriter = _pair.Application.Output; 1214var result = await _pair.Application.Input.ReadAsync().AsTask().DefaultTimeout(); 1222_pair.Application.Input.AdvanceTo(result.Buffer.Start, result.Buffer.End); 1232var 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(); 390Assert.True((await _pair.Application.Input.ReadAsync().AsTask().DefaultTimeout()).IsCompleted); 445Assert.True((await _pair.Application.Input.ReadAsync().AsTask().DefaultTimeout()).IsCompleted);