1 write to _pipe
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (1)
PipelineExtensionTests.cs (1)
24
_pipe
= new Pipe(new PipeOptions(_memoryPool, readerScheduler: PipeScheduler.Inline, writerScheduler: PipeScheduler.Inline, useSynchronizationContext: false));
14 references to _pipe
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (14)
PipelineExtensionTests.cs (14)
29
_pipe
.Reader.Complete();
30
_pipe
.Writer.Complete();
40
var writerBuffer =
_pipe
.Writer;
46
var reader =
_pipe
.Reader.ReadAsync().GetAwaiter().GetResult();
58
var writerBuffer =
_pipe
.Writer;
70
var reader =
_pipe
.Reader.ReadAsync().GetAwaiter().GetResult();
89
var pipeWriter =
_pipe
.Writer;
96
var reader =
_pipe
.Reader.ReadAsync().GetAwaiter().GetResult();
119
var writerBuffer =
_pipe
.Writer;
124
var reader =
_pipe
.Reader.ReadAsync().GetAwaiter().GetResult();
133
var writerBuffer =
_pipe
.Writer;
142
var reader =
_pipe
.Reader.ReadAsync().GetAwaiter().GetResult();
162
var writerBuffer =
_pipe
.Writer;
175
var reader =
_pipe
.Reader.ReadAsync().GetAwaiter().GetResult();