1 write to _pipe
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (1)
PipeThroughputBenchmark.cs (1)
23_pipe = new Pipe(new PipeOptions(_memoryPool));
10 references to _pipe
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (10)
PipeThroughputBenchmark.cs (10)
33_pipe.Writer.GetMemory(_writeLength); 34_pipe.Writer.Advance(_writeLength); 35await _pipe.Writer.FlushAsync(); 44var result = await _pipe.Reader.ReadAsync(); 46_pipe.Reader.AdvanceTo(result.Buffer.End, result.Buffer.End); 58_pipe.Writer.GetMemory(_writeLength); 59_pipe.Writer.Advance(_writeLength); 60_pipe.Writer.FlushAsync().GetAwaiter().GetResult(); 61var result = _pipe.Reader.ReadAsync().GetAwaiter().GetResult(); 62_pipe.Reader.AdvanceTo(result.Buffer.End, result.Buffer.End);