44 references to Reader
Aspire.Cli.Tests (4)
Mcp\TestMcpServerTransport.cs (4)
41ClientToServerPipe.Reader.AsStream(), 60serverOutput: ServerToClientPipe.Reader.AsStream(), 71ClientToServerPipe.Reader.Complete(); 73ServerToClientPipe.Reader.Complete();
Aspire.Hosting.Tests (1)
Dcp\DcpExecutorTests.cs (1)
617return s.Reader.AsStream();
Microsoft.AspNetCore.Components.Server (2)
Circuits\RemoteJSDataStream.cs (2)
79_pipeReaderStream = _pipe.Reader.AsStream(); 80PipeReader = _pipe.Reader;
Microsoft.AspNetCore.Http.Connections (3)
Internal\HttpConnectionContext.cs (1)
713var applicationToTransport = new DuplexPipe(input.Reader, Application.Output);
src\aspnetcore\src\SignalR\common\Shared\DuplexPipe.cs (2)
23var transportToApplication = new DuplexPipe(output.Reader, input.Writer); 24var applicationToTransport = new DuplexPipe(input.Reader, output.Writer);
Microsoft.AspNetCore.Server.Kestrel.Core (26)
Internal\Http\Http1ChunkedEncodingMessageBody.cs (5)
42_requestBodyPipe.Reader.AdvanceTo(consumed, examined); 49var boolResult = _requestBodyPipe.Reader.TryRead(out _readResult); 68var readAwaitable = _requestBodyPipe.Reader.ReadAsync(cancellationToken); 89_requestBodyPipe.Reader.CancelPendingRead(); 173_requestBodyPipe.Reader.Complete();
Internal\Http2\Http2Connection.cs (1)
213public PipeReader Input => _input.Reader;
Internal\Http2\Http2MessageBody.cs (7)
71_context.RequestBodyPipe.Reader.AdvanceTo(consumed, examined); 87var hasResult = _context.RequestBodyPipe.Reader.TryRead(out readResult); 111var readAwaitable = _context.RequestBodyPipe.Reader.ReadAsync(cancellationToken); 133_context.RequestBodyPipe.Reader.Complete(); 139return _context.RequestBodyPipe.Reader.CompleteAsync(); 144_context.RequestBodyPipe.Reader.CancelPendingRead(); 154_context.RequestBodyPipe.Reader.Complete();
Internal\Http2\Http2OutputProducer.cs (1)
71_pipeReader = _pipe.Reader;
Internal\Http2\Http2Stream.cs (1)
178RequestBodyPipe.Reader.Complete();
Internal\Http3\Http3MessageBody.cs (7)
46_context.RequestBodyPipe.Reader.AdvanceTo(consumed, examined); 55var hasResult = _context.RequestBodyPipe.Reader.TryRead(out readResult); 79var readAwaitable = _context.RequestBodyPipe.Reader.ReadAsync(cancellationToken); 101_context.RequestBodyPipe.Reader.Complete(); 107return _context.RequestBodyPipe.Reader.CompleteAsync(); 112_context.RequestBodyPipe.Reader.CancelPendingRead(); 122_context.RequestBodyPipe.Reader.Complete();
Internal\Http3\Http3OutputProducer.cs (1)
50_pipeReader = _pipe.Reader;
Internal\Http3\Http3Stream.cs (1)
589RequestBodyPipe.Reader.Complete();
src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipe.cs (2)
36var transportToApplication = new DuplexPipe(output.Reader, input.Writer); 37var applicationToTransport = new DuplexPipe(input.Reader, output.Writer);
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (4)
Internal\QuicStreamContext.cs (2)
66_transportPipeReader = new CompletionPipeReader(_inputPipe.Reader); 69_originalApplication = new DuplexPipe(_outputPipe.Reader, _inputPipe.Writer);
src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipe.cs (2)
36var transportToApplication = new DuplexPipe(output.Reader, input.Writer); 37var applicationToTransport = new DuplexPipe(input.Reader, output.Writer);
Microsoft.AspNetCore.Watch.BrowserRefresh (1)
src\sdk\src\Dotnet.Watch\Web.Middleware\ResponseStreamWrapper.cs (1)
139var gzipStream = new GZipStream(_pipe.Reader.AsStream(leaveOpen: true), CompressionMode.Decompress, leaveOpen: true);
Microsoft.Extensions.Http.Diagnostics (2)
Logging\Internal\HttpResponseBodyReader.cs (2)
108await pipe.Reader.CompleteAsync().ConfigureAwait(false); 118var newContent = new StreamContent(pipe.Reader.AsStream());
System.IO.Pipelines (1)
System\IO\Pipelines\Pipe.cs (1)
1139Reader.Complete(ThrowHelper.CreateInvalidOperationException_NoConcurrentOperation());