4 implementations of Output
Microsoft.AspNetCore.Http.Connections (1)
src\aspnetcore\src\SignalR\common\Shared\DuplexPipe.cs (1)
16public PipeWriter Output { get; }
Microsoft.AspNetCore.Server.Kestrel.Core (2)
src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipe.cs (1)
29public PipeWriter Output { get; }
src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)
38public PipeWriter Output { get; }
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (1)
src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipe.cs (1)
29public PipeWriter Output { get; }
41 references to Output
Microsoft.AspNetCore.Http.Connections (18)
Internal\HttpConnectionContext.cs (9)
72_applicationStream = new PipeWriterStream(application.Output); 194_applicationStream = new PipeWriterStream(value.Output); 303Application?.Output.CancelPendingFlush(); 324Application?.Output.Complete(); 341Transport?.Output.Complete(applicationTask.Exception?.InnerException); 356Application?.Output.Complete(); 366Application?.Output.Complete(transportTask.Exception?.InnerException); 383Transport?.Output.Complete(); 713var applicationToTransport = new DuplexPipe(input.Reader, Application.Output);
Internal\HttpConnectionDispatcher.cs (3)
229reconnectTask = connection.NotifyOnReconnect?.Invoke(connection.Transport.Output) ?? Task.CompletedTask; 265connection.Transport.Output.Complete(connection.ApplicationTask.Exception); 516connection.Application.Output.Complete();
Internal\Transports\WebSocketsServerTransport.cs (6)
121_application.Output.CancelPendingFlush(); 148var memory = _application.Output.GetMemory(); 161_application.Output.Advance(receiveResult.Count); 163var flushResult = await _application.Output.FlushAsync(); 187_application.Output.Complete(ex); 195_application.Output.Complete();
Microsoft.AspNetCore.Server.Kestrel.Core (12)
Internal\Http\Http1Connection.cs (4)
81_context.Transport.Output, 1079_context.Transport.Output.Write(Http2GoAwayHttp11RequiredBytes); 1080return _context.Transport.Output.FlushAsync().GetAsTask(); 1092var output = _context.Transport.Output;
Internal\Http2\Http2Connection.cs (2)
200context.Transport.Output, 597await _context.Transport.Output.WriteAsync(responseBytes);
Internal\Http3\Http3ControlStream.cs (1)
67_frameWriter.Reset(context.Transport.Output, context.ConnectionId);
Internal\Http3\Http3PendingStream.cs (1)
37Context.Transport.Output.Complete(exception);
Internal\Http3\Http3Stream.cs (1)
154_frameWriter.Reset(context.Transport.Output, context.ConnectionId);
Internal\WebTransport\WebTransportSession.cs (1)
140await stream.Transport.Output.WriteAsync(OutputStreamHeader, cancellationToken);
Internal\WebTransport\WebTransportStream.cs (1)
60_duplexPipe = new DuplexPipe(context.Transport.Input, context.Transport.Output);
src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)
26base(duplexPipe.Input, duplexPipe.Output)
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (2)
Internal\QuicStreamContext.cs (2)
74private PipeWriter Input => Application.Output; 554_originalTransport.Output.Complete();
Microsoft.AspNetCore.SignalR.Core (9)
HubConnectionContext.cs (8)
298Protocol.WriteMessage(message, _connectionContext.Transport.Output); 300return _connectionContext.Transport.Output.FlushAsync(cancellationToken); 338return _connectionContext.Transport.Output.WriteAsync(buffer, cancellationToken); 455await _connectionContext.Transport.Output.WriteAsync(_cachedPingMessage); 479_connectionContext.Transport.Output.Write(HandshakeProtocol.GetSuccessfulHandshake(Protocol)); 483HandshakeProtocol.WriteResponseMessage(message, _connectionContext.Transport.Output); 486await _connectionContext.Transport.Output.FlushAsync(); 515_connectionContext.Transport.Output.CancelPendingFlush();
src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (1)
78_writer = connection.Transport.Output;