595Application = application; 607duplexPipePair.Application = applicationToTransport;

35var res = await pipes.Application.Input.ReadAsync().DefaultTimeout(); 41pipes.Application.Input.AdvanceTo(buffer.Start); 60var res = await pipes.Application.Input.ReadAsync(); 66pipes.Application.Input.AdvanceTo(buffer.Start); 74res = await pipes.Application.Input.ReadAsync().DefaultTimeout(); 80pipes.Application.Input.AdvanceTo(buffer.Start); 102var res = await pipes.Application.Input.ReadAsync(); 107pipes.Application.Input.AdvanceTo(buffer.Start); 111res = await pipes.Application.Input.ReadAsync(); 116pipes.Application.Input.AdvanceTo(buffer.Start); 119Assert.False(pipes.Application.Input.TryRead(out res)); 135var res = await pipes.Application.Input.ReadAsync(); 141pipes.Application.Input.AdvanceTo(buffer.Start); 150res = await pipes.Application.Input.ReadAsync(); 157pipes.Application.Input.AdvanceTo(buffer.Start); 159res = await pipes.Application.Input.ReadAsync(); 165pipes.Application.Input.AdvanceTo(buffer.Start); 187var res = await pipes.Application.Input.ReadAsync(); 195pipes.Application.Input.AdvanceTo(buffer.Start); 204res = await pipes.Application.Input.ReadAsync(); 211pipes.Application.Input.AdvanceTo(buffer.Start); 213res = await pipes.Application.Input.ReadAsync(); 221pipes.Application.Input.AdvanceTo(buffer.Start); 240var res = await pipes.Application.Input.ReadAsync(); 246pipes.Application.Input.AdvanceTo(buffer.Start); 253res = await pipes.Application.Input.ReadAsync(); 260pipes.Application.Input.AdvanceTo(buffer.Start); 264res = await pipes.Application.Input.ReadAsync(); 270pipes.Application.Input.AdvanceTo(buffer.Start); 285var res = await pipes.Application.Input.ReadAsync(); 292pipes.Application.Input.AdvanceTo(buffer.Start); 317var res = await pipes.Application.Input.ReadAsync(); 324pipes.Application.Input.AdvanceTo(buffer.Start); 328res = await pipes.Application.Input.ReadAsync(); 334pipes.Application.Input.AdvanceTo(buffer.Start); 337Assert.False(pipes.Application.Input.TryRead(out res)); 354var res = await pipes.Application.Input.ReadAsync(); 360pipes.Application.Input.AdvanceTo(buffer.Start); 368res = await pipes.Application.Input.ReadAsync().DefaultTimeout(); 374pipes.Application.Input.AdvanceTo(buffer.Start); 389pipes.Application.Input.Complete(); 399var res = await pipes.Application.Input.ReadAsync(); 404pipes.Application.Input.AdvanceTo(buffer.Start); 408res = await pipes.Application.Input.ReadAsync(); 413pipes.Application.Input.AdvanceTo(buffer.Start); 416Assert.False(pipes.Application.Input.TryRead(out res)); 435var res = await pipes.Application.Input.ReadAsync(); 439pipes.Application.Input.AdvanceTo(buffer.Start); 447res = await pipes.Application.Input.ReadAsync(); 451pipes.Application.Input.AdvanceTo(buffer.Start); 479var res = await pipes.Application.Input.ReadAsync(); 483pipes.Application.Input.AdvanceTo(buffer.Start); 487res = await pipes.Application.Input.ReadAsync(); 491pipes.Application.Input.AdvanceTo(buffer.Start); 526var res = await pipes.Application.Input.ReadAsync(); 530pipes.Application.Input.AdvanceTo(buffer.Start); 536res = await pipes.Application.Input.ReadAsync(); 540pipes.Application.Input.AdvanceTo(buffer.Start); 545res = await pipes.Application.Input.ReadAsync(); 549pipes.Application.Input.AdvanceTo(buffer.Start); 551Assert.False(pipes.Application.Input.TryRead(out res)); 605var applicationToTransport = new DuplexPipe(input.Reader, duplexPipePair.Application.Output);