Writer

Mcp\TestMcpServerTransport.cs (4)

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

Dcp\DcpExecutorTests.cs (2)

651await pipes.StandardOut.Writer.WriteAsync(Encoding.UTF8.GetBytes("2024-08-19T06:10:33.473275911Z Hello world" + Environment.NewLine)); 662await pipes.StandardErr.Writer.WriteAsync(Encoding.UTF8.GetBytes("2024-08-19T06:10:32.661Z Next" + Environment.NewLine));

Circuits\RemoteJSDataStream.cs (2)

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

Internal\HttpConnectionContext.cs (1)

712var 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)

130done = Read(readableBuffer, _requestBodyPipe.Writer, out consumed, out examined); 132await _requestBodyPipe.Writer.FlushAsync(); 161await _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(); 506dataPayload.CopyTo(RequestBodyPipe.Writer); 512var flushTask = RequestBodyPipe.Writer.FlushAsync(); 547RequestBodyPipe.Writer.Complete(); 626RequestBodyPipe.Writer.Complete(abortReason);

Internal\Http3\Http3OutputProducer.cs (1)

49_pipeWriter = _pipe.Writer;

Internal\Http3\Http3Stream.cs (5)

204RequestBodyPipe.Writer.Complete(exception); 583RequestBodyPipe.Writer.Complete(); 784return RequestBodyPipe.Writer.CompleteAsync(); 966RequestBodyPipe.Writer.Write(segment.Span); 969return 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);

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

src\sdk\src\Dotnet.Watch\Web.Middleware\ResponseStreamWrapper.cs (2)

142_baseStream = _pipe.Writer.AsStream(leaveOpen: true); 180await _pipe.Writer.CompleteAsync();

Logging\Internal\HttpResponseBodyReader.cs (2)

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

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

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