Reader

Mcp\TestMcpServerTransport.cs (4)

41ClientToServerPipe.Reader.AsStream(), 60serverOutput: ServerToClientPipe.Reader.AsStream(), 71ClientToServerPipe.Reader.Complete(); 73ServerToClientPipe.Reader.Complete();

TestServices\TerminalTapeTestHost.cs (2)

37_outputReader = output.Reader.AsStream(); 39Input = input.Reader.AsStream();

Shared\TerminalTestHost.cs (2)

271var server = new DuplexStream(toServer.Reader.AsStream(), toClient.Writer.AsStream(), onDispose: null); 272var client = new DuplexStream(toClient.Reader.AsStream(), toServer.Writer.AsStream(), () => disconnected.TrySetResult());

BrowserHostTests.cs (2)

106_browserRead = _appToBrowser.Reader.AsStream(); 107_browserOutput = _browserToApp.Reader.AsStream();

BrowserLogsCdpConnectionTests.cs (4)

154await using var browserRead = appToBrowser.Reader.AsStream(); 159new BrowserLogsPipeCdpTransport(browserToApp.Reader.AsStream(), appToBrowser.Writer.AsStream()), 553new DuplexPipeStream(serverToClient.Reader, clientToServer.Writer), 554new DuplexPipeStream(clientToServer.Reader, serverToClient.Writer));

Dashboard\DashboardServiceTests.cs (4)

1505await using var reader = output.Reader.AsStream(); 1604await using var reader = output.Reader.AsStream(); 1635await using var reader = output.Reader.AsStream(); 1662await using var outputReader = output.Reader.AsStream();

Dcp\DcpExecutorTests.cs (4)

1949return s.Reader.AsStream(); 2367return new Pipe().Reader.AsStream(); 2464return timedOutFlushPipe.Reader.AsStream(); 2543return pipe.Reader.AsStream();

Terminals\Hex1bAspireTerminalTests.cs (11)

Terminals\InteractionServiceTerminalTests.cs (2)

362await using var outputReader = output.Reader.AsStream(); 395await using var outputReader = output.Reader.AsStream();

Terminals\TerminalKeyInputTests.cs (2)

32await using var outputReader = output.Reader.AsStream(); 34await using var inputReader = input.Reader.AsStream();

Utils\TestDuplexStream.cs (2)

15new TestDuplexStream(secondToFirst.Reader.AsStream(), firstToSecond.Writer.AsStream()), 16new TestDuplexStream(firstToSecond.Reader.AsStream(), secondToFirst.Writer.AsStream()));

Circuits\RemoteJSDataStream.cs (2)

79_pipeReaderStream = _pipe.Reader.AsStream(); 80PipeReader = _pipe.Reader;

Internal\HttpConnectionContext.cs (1)

1083var 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);

Internal\WebSocketsTransport.cs (1)

711var 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);

Core\IISHttpContext.IO.cs (3)

30var result = await _bodyInputPipe!.Reader.ReadAsync(cancellationToken); 48_bodyInputPipe.Reader.AdvanceTo(readableBuffer.End, readableBuffer.End); 60return _bodyInputPipe!.Reader.CopyToAsync(destination, cancellationToken);

Core\IISHttpContextOfT.cs (1)

111_bodyInputPipe?.Reader.Complete();

Core\OutputProducer.cs (3)

31public PipeReader Reader => _pipe.Reader; 37_pipe.Reader.CancelPendingRead(); 67_pipe.Reader.CancelPendingRead();

src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipe.cs (2)

36var transportToApplication = new DuplexPipe(output.Reader, input.Writer); 37var applicationToTransport = new DuplexPipe(input.Reader, output.Writer);

Internal\Http\Http1ChunkedEncodingMessageBody.cs (5)

44_requestBodyPipe.Reader.AdvanceTo(consumed, examined); 51var boolResult = _requestBodyPipe.Reader.TryRead(out _readResult); 70var readAwaitable = _requestBodyPipe.Reader.ReadAsync(cancellationToken); 91_requestBodyPipe.Reader.CancelPendingRead(); 175_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); 112var readAwaitable = _context.RequestBodyPipe.Reader.ReadAsync(cancellationToken); 134_context.RequestBodyPipe.Reader.Complete(); 140return _context.RequestBodyPipe.Reader.CompleteAsync(); 145_context.RequestBodyPipe.Reader.CancelPendingRead(); 155_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); 80var readAwaitable = _context.RequestBodyPipe.Reader.ReadAsync(cancellationToken); 102_context.RequestBodyPipe.Reader.Complete(); 108return _context.RequestBodyPipe.Reader.CompleteAsync(); 113_context.RequestBodyPipe.Reader.CancelPendingRead(); 123_context.RequestBodyPipe.Reader.Complete();

Internal\Http3\Http3OutputProducer.cs (1)

50_pipeReader = _pipe.Reader;

Internal\Http3\Http3Stream.cs (1)

633RequestBodyPipe.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);

src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipe.cs (2)

36var transportToApplication = new DuplexPipe(output.Reader, input.Writer); 37var applicationToTransport = new DuplexPipe(input.Reader, output.Writer);

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

src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipe.cs (2)

36var transportToApplication = new DuplexPipe(output.Reader, input.Writer); 37var applicationToTransport = new DuplexPipe(input.Reader, output.Writer);

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

HttpContextBuilder.cs (4)

65configureContext(_httpContext, _requestPipe.Reader); 134await _requestPipe.Reader.CompleteAsync(); 196return !_requestPipe.Reader.TryRead(out var result) || !result.IsCompleted; 264_requestPipe.Reader.CancelPendingRead();

ResponseBodyReaderStream.cs (4)

87var result = await _pipe.Reader.ReadAsync(cancellationToken); 105_pipe.Reader.AdvanceTo(readableBuffer.End); 124_pipe.Reader.CancelPendingRead(); 145_pipe.Reader.Complete();

Logging\Internal\HttpResponseBodyReader.cs (2)

110await pipe.Reader.CompleteAsync().ConfigureAwait(false); 120var newContent = new StreamContent(pipe.Reader.AsStream());

System\IO\Pipelines\Pipe.cs (1)

1250Reader.Complete(ThrowHelper.CreateInvalidOperationException_NoConcurrentOperation());