38 references to Writer
Aspire.Cli.Tests (4)
Mcp\TestMcpServerTransport.cs (4)
42ServerToClientPipe.Writer.AsStream(), 59serverInput: ClientToServerPipe.Writer.AsStream(), 72ClientToServerPipe.Writer.Complete(); 74ServerToClientPipe.Writer.Complete();
Aspire.Hosting.Tests (2)
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));
Microsoft.AspNetCore.Components.Server (2)
Circuits\RemoteJSDataStream.cs (2)
125await _pipe.Writer.WriteAsync(chunk, _streamCancellationToken); 219await _pipe.Writer.CompleteAsync(ex);
Microsoft.AspNetCore.Http.Connections (3)
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);
Microsoft.AspNetCore.Server.Kestrel.Core (18)
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(); 503dataPayload.CopyTo(RequestBodyPipe.Writer); 509var flushTask = RequestBodyPipe.Writer.FlushAsync(); 544RequestBodyPipe.Writer.Complete(); 623RequestBodyPipe.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);
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (4)
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);
Microsoft.AspNetCore.Watch.BrowserRefresh (2)
src\sdk\src\Dotnet.Watch\Web.Middleware\ResponseStreamWrapper.cs (2)
142_baseStream = _pipe.Writer.AsStream(leaveOpen: true); 180await _pipe.Writer.CompleteAsync();
Microsoft.Extensions.Http.Diagnostics (2)
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 (1)
System\IO\Pipelines\Pipe.cs (1)
926Writer.Complete(ThrowHelper.CreateInvalidOperationException_NoConcurrentOperation());