538Application = application; 550duplexPipePair.Application = applicationToTransport;

34var res = await pipes.Application.Input.ReadAsync().DefaultTimeout(); 40pipes.Application.Input.AdvanceTo(buffer.Start); 59var res = await pipes.Application.Input.ReadAsync(); 65pipes.Application.Input.AdvanceTo(buffer.Start); 73res = await pipes.Application.Input.ReadAsync().DefaultTimeout(); 79pipes.Application.Input.AdvanceTo(buffer.Start); 101var res = await pipes.Application.Input.ReadAsync(); 106pipes.Application.Input.AdvanceTo(buffer.Start); 110res = await pipes.Application.Input.ReadAsync(); 115pipes.Application.Input.AdvanceTo(buffer.Start); 118Assert.False(pipes.Application.Input.TryRead(out res)); 134var res = await pipes.Application.Input.ReadAsync(); 140pipes.Application.Input.AdvanceTo(buffer.Start); 149res = await pipes.Application.Input.ReadAsync(); 156pipes.Application.Input.AdvanceTo(buffer.Start); 158res = await pipes.Application.Input.ReadAsync(); 164pipes.Application.Input.AdvanceTo(buffer.Start); 183var res = await pipes.Application.Input.ReadAsync(); 189pipes.Application.Input.AdvanceTo(buffer.Start); 196res = await pipes.Application.Input.ReadAsync(); 203pipes.Application.Input.AdvanceTo(buffer.Start); 207res = await pipes.Application.Input.ReadAsync(); 213pipes.Application.Input.AdvanceTo(buffer.Start); 228var res = await pipes.Application.Input.ReadAsync(); 235pipes.Application.Input.AdvanceTo(buffer.Start); 260var res = await pipes.Application.Input.ReadAsync(); 267pipes.Application.Input.AdvanceTo(buffer.Start); 271res = await pipes.Application.Input.ReadAsync(); 277pipes.Application.Input.AdvanceTo(buffer.Start); 280Assert.False(pipes.Application.Input.TryRead(out res)); 297var res = await pipes.Application.Input.ReadAsync(); 303pipes.Application.Input.AdvanceTo(buffer.Start); 311res = await pipes.Application.Input.ReadAsync().DefaultTimeout(); 317pipes.Application.Input.AdvanceTo(buffer.Start); 332pipes.Application.Input.Complete(); 342var res = await pipes.Application.Input.ReadAsync(); 347pipes.Application.Input.AdvanceTo(buffer.Start); 351res = await pipes.Application.Input.ReadAsync(); 356pipes.Application.Input.AdvanceTo(buffer.Start); 359Assert.False(pipes.Application.Input.TryRead(out res)); 378var res = await pipes.Application.Input.ReadAsync(); 382pipes.Application.Input.AdvanceTo(buffer.Start); 390res = await pipes.Application.Input.ReadAsync(); 394pipes.Application.Input.AdvanceTo(buffer.Start); 422var res = await pipes.Application.Input.ReadAsync(); 426pipes.Application.Input.AdvanceTo(buffer.Start); 430res = await pipes.Application.Input.ReadAsync(); 434pipes.Application.Input.AdvanceTo(buffer.Start); 469var res = await pipes.Application.Input.ReadAsync(); 473pipes.Application.Input.AdvanceTo(buffer.Start); 479res = await pipes.Application.Input.ReadAsync(); 483pipes.Application.Input.AdvanceTo(buffer.Start); 488res = await pipes.Application.Input.ReadAsync(); 492pipes.Application.Input.AdvanceTo(buffer.Start); 494Assert.False(pipes.Application.Input.TryRead(out res)); 548var applicationToTransport = new DuplexPipe(input.Reader, duplexPipePair.Application.Output);