Output

src\aspnetcore\src\SignalR\common\Shared\DuplexPipe.cs (1)

16public PipeWriter Output { get; }

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

src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipe.cs (1)

29public PipeWriter Output { get; }

src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)

38public PipeWriter Output { get; }

src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipe.cs (1)

29public PipeWriter Output { get; }

src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)

38public PipeWriter Output { get; }

src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipe.cs (1)

29public PipeWriter Output { get; }

src\aspnetcore\src\SignalR\common\Shared\DuplexPipe.cs (1)

16public PipeWriter Output { get; }

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

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

src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)

26base(duplexPipe.Input, duplexPipe.Output)

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)

Internal\QuicStreamContext.cs (2)

74private PipeWriter Input => Application.Output; 558_originalTransport.Output.Complete();

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;

HubConnectionContext.cs (8)

src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (1)

78_writer = connection.Transport.Output;

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