1 write to Pipe
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (1)
BufferWriterTests.cs (1)
16Pipe = new Pipe(new PipeOptions(useSynchronizationContext: false, pauseWriterThreshold: 0, resumeWriterThreshold: 0));
23 references to Pipe
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (23)
BufferWriterTests.cs (23)
21Pipe.Writer.Complete(); 22Pipe.Reader.Complete(); 27Pipe.Writer.FlushAsync().GetAwaiter().GetResult(); 28Pipe.Writer.Complete(); 29ReadResult readResult = Pipe.Reader.ReadAsync().GetAwaiter().GetResult(); 31Pipe.Reader.AdvanceTo(readResult.Buffer.End); 44BufferWriter<PipeWriter> writer = new BufferWriter<PipeWriter>(Pipe.Writer); 77BufferWriter<PipeWriter> writer = new BufferWriter<PipeWriter>(Pipe.Writer); 94BufferWriter<PipeWriter> writer = new BufferWriter<PipeWriter>(Pipe.Writer); 108BufferWriter<PipeWriter> writer = new BufferWriter<PipeWriter>(Pipe.Writer); 120BufferWriter<PipeWriter> writer = new BufferWriter<PipeWriter>(Pipe.Writer); 134Memory<byte> memory = Pipe.Writer.GetMemory(); 135BufferWriter<PipeWriter> writer = new BufferWriter<PipeWriter>(Pipe.Writer); 150BufferWriter<PipeWriter> writer = new BufferWriter<PipeWriter>(Pipe.Writer); 160int initialLength = Pipe.Writer.GetMemory().Length; 161BufferWriter<PipeWriter> writer = new BufferWriter<PipeWriter>(Pipe.Writer); 169int initialLength = Pipe.Writer.GetMemory().Length; 171BufferWriter<PipeWriter> writer = new BufferWriter<PipeWriter>(Pipe.Writer); 178Assert.Equal(Pipe.Writer.GetMemory().Length, writer.Span.Length); 185BufferWriter<PipeWriter> writer = new BufferWriter<PipeWriter>(Pipe.Writer); 201Pipe.Writer.FlushAsync().GetAwaiter().GetResult(); 202var readResult = Pipe.Reader.ReadAsync().GetAwaiter().GetResult(); 221BufferWriter<PipeWriter> writer = new BufferWriter<PipeWriter>(Pipe.Writer);