Writer

Mcp\TestMcpServerTransport.cs (4)

42ServerToClientPipe.Writer.AsStream(), 59serverInput: ClientToServerPipe.Writer.AsStream(), 72ClientToServerPipe.Writer.Complete(); 74ServerToClientPipe.Writer.Complete();

TestServices\TerminalTapeTestHost.cs (2)

38Output = output.Writer.AsStream(); 40_inputWriter = input.Writer.AsStream();

Shared\TerminalTestHost.cs (2)

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

BrowserHostTests.cs (2)

105_browserInput = _appToBrowser.Writer.AsStream(); 108_browserWrite = _browserToApp.Writer.AsStream();

BrowserLogsCdpConnectionTests.cs (4)

155await using var browserWrite = browserToApp.Writer.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)

1506await using var writer = output.Writer.AsStream(); 1605await using var writer = output.Writer.AsStream(); 1636await using var writer = output.Writer.AsStream(); 1663await using var outputWriter = output.Writer.AsStream();

Dcp\DcpExecutorTests.cs (4)

1749await pipes.StandardOut.Writer.WriteAsync(Encoding.UTF8.GetBytes("2024-08-19T06:10:33.473275911Z Hello world" + Environment.NewLine)); 1760await pipes.StandardErr.Writer.WriteAsync(Encoding.UTF8.GetBytes("2024-08-19T06:10:32.661Z Next" + Environment.NewLine)); 2283timedOutFlushPipe.Writer.Complete(); 2359await followStdErrPipe.Writer.WriteAsync(Encoding.UTF8.GetBytes("same" + Environment.NewLine + "same" + Environment.NewLine));

Terminals\Hex1bAspireTerminalTests.cs (11)

Terminals\InteractionServiceTerminalTests.cs (2)

363await using var outputWriter = output.Writer.AsStream(); 396await using var outputWriter = output.Writer.AsStream();

Terminals\TerminalKeyInputTests.cs (2)

33await using var outputWriter = output.Writer.AsStream(); 35await using var inputWriter = input.Writer.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)

125await _pipe.Writer.WriteAsync(chunk, _streamCancellationToken); 219await _pipe.Writer.CompleteAsync(ex);

Internal\HttpConnectionContext.cs (1)

1082var transportToApplication = new DuplexPipe(Transport.Input, input.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);

Internal\WebSocketsTransport.cs (1)

710var transportToApplication = new DuplexPipe(_transport!.Input, input.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);

Core\IISHttpContext.IO.cs (4)

103var memory = _bodyInputPipe!.Writer.GetMemory(); 117_bodyInputPipe.Writer.Advance(read); 125var result = await _bodyInputPipe.Writer.FlushAsync(); 151_bodyInputPipe!.Writer.Complete(error);

Core\OutputProducer.cs (5)

39return FlushAsync(_pipe.Writer, cancellationToken); 52_pipe.Writer.Complete(); 68_pipe.Writer.Complete(); 81_pipe.Writer.Write(buffer.Span); 84return FlushAsync(_pipe.Writer, cancellationToken);

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

132done = Read(readableBuffer, _requestBodyPipe.Writer, out consumed, out examined); 134await _requestBodyPipe.Writer.FlushAsync(); 163await _requestBodyPipe.Writer.CompleteAsync(error);

Internal\Http2\Http2Connection.cs (1)

197_inputTask = CopyPipeAsync(_context.Transport.Input, _input.Writer);

Internal\Http2\Http2OutputProducer.cs (1)

70_pipeWriter = new ConcurrentPipeWriter(_pipe.Writer, _memoryPool, _dataWriterLock);

Internal\Http2\Http2Stream.cs (5)

172RequestBodyPipe.Writer.Complete(); 513dataPayload.CopyTo(RequestBodyPipe.Writer); 519var flushTask = RequestBodyPipe.Writer.FlushAsync(); 554RequestBodyPipe.Writer.Complete(); 633RequestBodyPipe.Writer.Complete(abortReason);

Internal\Http3\Http3OutputProducer.cs (1)

49_pipeWriter = _pipe.Writer;

Internal\Http3\Http3Stream.cs (5)

226RequestBodyPipe.Writer.Complete(exception); 627RequestBodyPipe.Writer.Complete(); 833return RequestBodyPipe.Writer.CompleteAsync(); 1015RequestBodyPipe.Writer.Write(segment.Span); 1018return RequestBodyPipe.Writer.FlushAsync().GetAsTask();

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)

67_transportPipeWriter = new CompletionPipeWriter(_outputPipe.Writer); 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 (2)

108var requestTask = _sendRequestStream(_requestPipe.Writer); 263_requestPipe.Writer.CancelPendingFlush();

ResponseBodyPipeWriter.cs (9)

30return await _pipe.Writer.FlushAsync(cancellationToken); 47_pipe.Writer.Complete(new IOException(string.Empty, innerException)); 59_pipe.Writer.Complete(); 79public override void CancelPendingFlush() => _pipe.Writer.CancelPendingFlush(); 84_pipe.Writer.Advance(bytes); 90return _pipe.Writer.GetMemory(sizeHint); 96return _pipe.Writer.GetSpan(sizeHint); 99public override bool CanGetUnflushedBytes => _pipe.Writer.CanGetUnflushedBytes; 101public override long UnflushedBytes => _pipe.Writer.UnflushedBytes;

Logging\Internal\HttpResponseBodyReader.cs (2)

103string bufferedString = await BufferStreamAndWriteToPipeAsync(streamToReadFrom, pipe.Writer, readSizeLimit, cancellationToken).ConfigureAwait(false); 117_ = WriteStreamToPipeAsync(streamToReadFrom, pipe.Writer, cancellationToken);

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

1037Writer.Complete(ThrowHelper.CreateInvalidOperationException_NoConcurrentOperation());