740Application = application; 752duplexPipePair.Application = applicationToTransport;

36var res = await pipes.Application.Input.ReadAsync().DefaultTimeout(); 42pipes.Application.Input.AdvanceTo(buffer.Start); 62var res = await pipes.Application.Input.ReadAsync(); 68pipes.Application.Input.AdvanceTo(buffer.Start); 76res = await pipes.Application.Input.ReadAsync().DefaultTimeout(); 82pipes.Application.Input.AdvanceTo(buffer.Start); 105var res = await pipes.Application.Input.ReadAsync(); 110pipes.Application.Input.AdvanceTo(buffer.Start); 114res = await pipes.Application.Input.ReadAsync(); 119pipes.Application.Input.AdvanceTo(buffer.Start); 122Assert.False(pipes.Application.Input.TryRead(out res)); 139var res = await pipes.Application.Input.ReadAsync(); 145pipes.Application.Input.AdvanceTo(buffer.Start); 154res = await pipes.Application.Input.ReadAsync(); 161pipes.Application.Input.AdvanceTo(buffer.Start); 163res = await pipes.Application.Input.ReadAsync(); 169pipes.Application.Input.AdvanceTo(buffer.Start); 192var res = await pipes.Application.Input.ReadAsync(); 200pipes.Application.Input.AdvanceTo(buffer.Start); 209res = await pipes.Application.Input.ReadAsync(); 216pipes.Application.Input.AdvanceTo(buffer.Start); 218res = await pipes.Application.Input.ReadAsync(); 226pipes.Application.Input.AdvanceTo(buffer.Start); 246var res = await pipes.Application.Input.ReadAsync(); 252pipes.Application.Input.AdvanceTo(buffer.Start); 259res = await pipes.Application.Input.ReadAsync(); 266pipes.Application.Input.AdvanceTo(buffer.Start); 270res = await pipes.Application.Input.ReadAsync(); 276pipes.Application.Input.AdvanceTo(buffer.Start); 291var res = await pipes.Application.Input.ReadAsync(); 298pipes.Application.Input.AdvanceTo(buffer.Start); 324var res = await pipes.Application.Input.ReadAsync(); 331pipes.Application.Input.AdvanceTo(buffer.Start); 335res = await pipes.Application.Input.ReadAsync(); 341pipes.Application.Input.AdvanceTo(buffer.Start); 344Assert.False(pipes.Application.Input.TryRead(out res)); 362var res = await pipes.Application.Input.ReadAsync(); 368pipes.Application.Input.AdvanceTo(buffer.Start); 376res = await pipes.Application.Input.ReadAsync().DefaultTimeout(); 382pipes.Application.Input.AdvanceTo(buffer.Start); 398pipes.Application.Input.Complete(); 408var res = await pipes.Application.Input.ReadAsync(); 413pipes.Application.Input.AdvanceTo(buffer.Start); 417res = await pipes.Application.Input.ReadAsync(); 422pipes.Application.Input.AdvanceTo(buffer.Start); 425Assert.False(pipes.Application.Input.TryRead(out res)); 444var res = await pipes.Application.Input.ReadAsync(); 448pipes.Application.Input.AdvanceTo(buffer.Start); 456res = await pipes.Application.Input.ReadAsync(); 460pipes.Application.Input.AdvanceTo(buffer.Start); 489var res = await pipes.Application.Input.ReadAsync(); 493pipes.Application.Input.AdvanceTo(buffer.Start); 497res = await pipes.Application.Input.ReadAsync(); 501pipes.Application.Input.AdvanceTo(buffer.Start); 537var res = await pipes.Application.Input.ReadAsync(); 541pipes.Application.Input.AdvanceTo(buffer.Start); 547res = await pipes.Application.Input.ReadAsync(); 551pipes.Application.Input.AdvanceTo(buffer.Start); 556res = await pipes.Application.Input.ReadAsync(); 560pipes.Application.Input.AdvanceTo(buffer.Start); 562Assert.False(pipes.Application.Input.TryRead(out res)); 589var res = await pipes.Application.Input.ReadAsync(); 594pipes.Application.Input.AdvanceTo(buffer.Start); 598res = await pipes.Application.Input.ReadAsync(); 603pipes.Application.Input.AdvanceTo(buffer.Start); 606Assert.False(pipes.Application.Input.TryRead(out res)); 636var res = await pipes.Application.Input.ReadAsync(); 641pipes.Application.Input.AdvanceTo(buffer.Start); 643res = await pipes.Application.Input.ReadAsync(); 648pipes.Application.Input.AdvanceTo(buffer.Start); 650Assert.False(pipes.Application.Input.TryRead(out res)); 680var res = await pipes.Application.Input.ReadAsync(); 685pipes.Application.Input.AdvanceTo(buffer.Start); 687res = await pipes.Application.Input.ReadAsync(); 692pipes.Application.Input.AdvanceTo(buffer.Start); 694Assert.False(pipes.Application.Input.TryRead(out res)); 750var applicationToTransport = new DuplexPipe(input.Reader, duplexPipePair.Application.Output);