11 implementations of Output
Microsoft.AspNetCore.Http.Connections (1)
src\aspnetcore\src\SignalR\common\Shared\DuplexPipe.cs (1)
16public PipeWriter Output { get; }
Microsoft.AspNetCore.Http.Connections.Client (4)
Internal\LongPollingTransport.cs (1)
34public PipeWriter Output => _transport!.Output;
Internal\ServerSentEventsTransport.cs (1)
35public PipeWriter Output => _transport!.Output;
Internal\WebSocketsTransport.cs (1)
53public PipeWriter Output => _transport!.Output;
src\aspnetcore\src\SignalR\common\Shared\DuplexPipe.cs (1)
16public PipeWriter Output { get; }
Microsoft.AspNetCore.Server.IIS (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.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; }
Microsoft.AspNetCore.SignalR.Specification.Tests (1)
src\aspnetcore\src\SignalR\common\Shared\DuplexPipe.cs (1)
16public PipeWriter Output { get; }
72 references to Output
Microsoft.AspNetCore.Http.Connections (18)
Internal\HttpConnectionContext.cs (9)
79_applicationStream = new PipeWriterStream(application.Output); 202_applicationStream = new PipeWriterStream(value.Output); 430Application?.Output.CancelPendingFlush(); 451Application?.Output.Complete(); 468Transport?.Output.Complete(applicationTask.Exception?.InnerException); 483Application?.Output.Complete(); 493Application?.Output.Complete(transportTask.Exception?.InnerException); 510Transport?.Output.Complete(); 840var applicationToTransport = new DuplexPipe(input.Reader, Application.Output);
Internal\HttpConnectionDispatcher.cs (3)
452reconnectTask = connection.NotifyOnReconnect?.Invoke(connection.Transport.Output) ?? Task.CompletedTask; 488connection.Transport.Output.Complete(connection.ApplicationTask.Exception); 756connection.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.Http.Connections.Client (22)
Internal\LongPollingTransport.cs (6)
34public PipeWriter Output => _transport!.Output; 104_application.Output.CancelPendingFlush(); 135_transport!.Output.Complete(); 148var applicationStream = new PipeWriterStream(_application.Output); 198var flushResult = await _application.Output.FlushAsync(cancellationToken).ConfigureAwait(false); 222_application.Output.Complete(_error);
Internal\ServerSentEventsTransport.cs (5)
35public PipeWriter Output => _transport!.Output; 120_application.Output.CancelPendingFlush(); 146var flushResult = await _application.Output.WriteAsync(item.Data, default).ConfigureAwait(false); 167_application.Output.Complete(_error); 184_transport!.Output.Complete();
Internal\WebSocketsTransport.cs (11)
53public PipeWriter Output => _transport!.Output; 350await _notifyOnReconnect.Invoke(_transport!.Output).ConfigureAwait(false); 394_application.Output.CancelPendingFlush(); 427_application.Output.Complete(); 458var memory = _application.Output.GetMemory(); 487_application.Output.Advance(receiveResult.Count); 489var flushResult = await _application.Output.FlushAsync().ConfigureAwait(false); 509_application.Output.Complete(ex); 523_application.Output.Complete(); 666_transport!.Output.Complete(); 711var applicationToTransport = new DuplexPipe(input.Reader, _application!.Output);
Microsoft.AspNetCore.Server.IIS (1)
src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)
26base(duplexPipe.Input, duplexPipe.Output)
Microsoft.AspNetCore.Server.Kestrel.Core (12)
Internal\Http\Http1Connection.cs (4)
84_context.Transport.Output, 1105_context.Transport.Output.Write(Http2GoAwayHttp11RequiredBytes); 1106return _context.Transport.Output.FlushAsync().GetAsTask(); 1118var 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; 558_originalTransport.Output.Complete();
Microsoft.AspNetCore.SignalR.Client.Core (5)
HubConnection.cs (4)
1393_protocol.WriteMessage(hubMessage, connectionState.Connection.Transport.Output); 1395await connectionState.Connection.Transport.Output.FlushAsync(cancellationToken).ConfigureAwait(false); 1671HandshakeProtocol.WriteRequestMessage(handshakeRequest, startingConnectionState.Connection.Transport.Output); 1673var sendHandshakeResult = await startingConnectionState.Connection.Transport.Output.FlushAsync(CancellationToken.None).ConfigureAwait(false);
src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (1)
78_writer = connection.Transport.Output;
Microsoft.AspNetCore.SignalR.Core (9)
HubConnectionContext.cs (8)
371Protocol.WriteMessage(message, _connectionContext.Transport.Output); 373return _connectionContext.Transport.Output.FlushAsync(cancellationToken); 411return _connectionContext.Transport.Output.WriteAsync(buffer, cancellationToken); 528await _connectionContext.Transport.Output.WriteAsync(_cachedPingMessage); 552_connectionContext.Transport.Output.Write(HandshakeProtocol.GetSuccessfulHandshake(Protocol)); 556HandshakeProtocol.WriteResponseMessage(message, _connectionContext.Transport.Output); 559await _connectionContext.Transport.Output.FlushAsync(); 588_connectionContext.Transport.Output.CancelPendingFlush();
src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (1)
78_writer = connection.Transport.Output;
Microsoft.AspNetCore.SignalR.Specification.Tests (3)
src\aspnetcore\src\SignalR\common\testassets\Tests.Utils\TestClient.cs (3)
75await Connection.Application.Output.WriteAsync(GetHandshakeRequestMessage()); 236await Connection.Application.Output.WriteAsync(payload); 314Connection.Application.Output.Complete();