Reader

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());