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();
39
var writerBuffer =
_pipe
.Writer;
45
var reader =
_pipe
.Reader.ReadAsync().GetAwaiter().GetResult();
56
var writerBuffer =
_pipe
.Writer;
62
var readResult =
_pipe
.Reader.ReadAsync().GetAwaiter().GetResult();
66
_pipe
.Reader.AdvanceTo(readResult.Buffer.End);
76
var writerBuffer =
_pipe
.Writer;
88
var reader =
_pipe
.Reader.ReadAsync().GetAwaiter().GetResult();
107
var pipeWriter =
_pipe
.Writer;
114
var reader =
_pipe
.Reader.ReadAsync().GetAwaiter().GetResult();
137
var writerBuffer =
_pipe
.Writer;
142
var reader =
_pipe
.Reader.ReadAsync().GetAwaiter().GetResult();
151
var writerBuffer =
_pipe
.Writer;
160
var reader =
_pipe
.Reader.ReadAsync().GetAwaiter().GetResult();
180
var writerBuffer =
_pipe
.Writer;
193
var reader =
_pipe
.Reader.ReadAsync().GetAwaiter().GetResult();