1 write to _pipe
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (1)
PipelineExtensionTests.cs (1)
23_pipe = new Pipe(new PipeOptions(_memoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false));
17 references to _pipe
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (17)
PipelineExtensionTests.cs (17)
28_pipe.Reader.Complete(); 29_pipe.Writer.Complete(); 39var writerBuffer = _pipe.Writer; 45var reader = _pipe.Reader.ReadAsync().GetAwaiter().GetResult(); 56var writerBuffer = _pipe.Writer; 62var readResult = _pipe.Reader.ReadAsync().GetAwaiter().GetResult(); 66_pipe.Reader.AdvanceTo(readResult.Buffer.End); 76var writerBuffer = _pipe.Writer; 88var reader = _pipe.Reader.ReadAsync().GetAwaiter().GetResult(); 107var pipeWriter = _pipe.Writer; 114var reader = _pipe.Reader.ReadAsync().GetAwaiter().GetResult(); 137var writerBuffer = _pipe.Writer; 142var reader = _pipe.Reader.ReadAsync().GetAwaiter().GetResult(); 151var writerBuffer = _pipe.Writer; 160var reader = _pipe.Reader.ReadAsync().GetAwaiter().GetResult(); 180var writerBuffer = _pipe.Writer; 193var reader = _pipe.Reader.ReadAsync().GetAwaiter().GetResult();