Output

34 implementations of Output

ClientSample (1)

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

16public PipeWriter Output { get; }

http2cat (1)

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

38public PipeWriter Output { get; }

IIS.FunctionalTests (1)

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

38public PipeWriter Output { get; }

IIS.LongTests (1)

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

38public PipeWriter Output { get; }

IIS.NewHandler.FunctionalTests (1)

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

38public PipeWriter Output { get; }

IIS.NewShim.FunctionalTests (1)

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

38public PipeWriter Output { get; }

IIS.ShadowCopy.Tests (1)

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

38public PipeWriter Output { get; }

IISExpress.FunctionalTests (1)

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

38public PipeWriter Output { get; }

InMemory.FunctionalTests (2)

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)

37public PipeWriter Output { get; }

TestTransport\InMemoryTransportConnection.cs (1)

113public PipeWriter Output { get; }

Microsoft.AspNetCore.Http.Connections (1)

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\SignalR\common\Shared\DuplexPipe.cs (1)

16public PipeWriter Output { get; }

Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (1)

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

38public PipeWriter Output { get; }

Microsoft.AspNetCore.Server.IIS (2)

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

29public PipeWriter Output { get; }

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

38public PipeWriter Output { get; }

Microsoft.AspNetCore.Server.Kestrel.Core (2)

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

29public PipeWriter Output { get; }

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

38public PipeWriter Output { get; }

Microsoft.AspNetCore.Server.Kestrel.Core.Tests (1)

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)

37public PipeWriter Output { get; }

Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (1)

Mocks\MockDuplexPipe.cs (1)

17public PipeWriter Output { get; }

Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (1)

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

29public PipeWriter Output { get; }

Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (1)

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

29public PipeWriter Output { get; }

Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets (1)

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

29public PipeWriter Output { get; }

Microsoft.AspNetCore.Shared.Tests (2)

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

29public PipeWriter Output { get; }

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

38public PipeWriter Output { get; }

Microsoft.AspNetCore.SignalR.Microbenchmarks (1)

Shared\TestDuplexPipe.cs (1)

14public PipeWriter Output { get; }

Microsoft.AspNetCore.SignalR.Specification.Tests (1)

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

16public PipeWriter Output { get; }

Microsoft.AspNetCore.SignalR.Tests (2)

HubConnectionHandlerTests.cs (1)

3001public PipeWriter Output => _originalDuplexPipe.Output;

Internal\MessageBufferTests.cs (1)

516public PipeWriter Output { get; }

Microsoft.AspNetCore.SignalR.Tests.Utils (1)

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

16public PipeWriter Output { get; }

Sockets.FunctionalTests (2)

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)

37public PipeWriter Output { get; }

src\Servers\Kestrel\test\FunctionalTests\ConnectionMiddlewareTests.cs (1)

86public PipeWriter Output => new MockPipeWriter(this);

278 references to Output

ClientSample (6)

RawSample.cs (1)

58_ = SendLoop(Console.In, connection.Transport.Output);

Tcp\TcpConnection.cs (5)

51Transport?.Output.Complete(); 153_application.Output.Complete(error); 162var buffer = _application.Output.GetMemory(); 172_application.Output.Advance(bytesReceived); 174var result = await _application.Output.FlushAsync();

http2cat (1)

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

26base(duplexPipe.Input, duplexPipe.Output)

IIS.FunctionalTests (1)

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

26base(duplexPipe.Input, duplexPipe.Output)

IIS.LongTests (1)

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

26base(duplexPipe.Input, duplexPipe.Output)

IIS.NewHandler.FunctionalTests (1)

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

26base(duplexPipe.Input, duplexPipe.Output)

IIS.NewShim.FunctionalTests (1)

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

26base(duplexPipe.Input, duplexPipe.Output)

IIS.ShadowCopy.Tests (1)

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

26base(duplexPipe.Input, duplexPipe.Output)

IISExpress.FunctionalTests (1)

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

26base(duplexPipe.Input, duplexPipe.Output)

InMemory.FunctionalTests (6)

Http3\WebTransport\WebTransportStreamTests.cs (2)

42await stream.Transport.Output.WriteAsync(input, CancellationToken.None); 44await stream.Transport.Output.FlushAsync();

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)

32Output = new PassThroughPipeWriter(duplexPipe.Output);

TestTransport\InMemoryTransportConnection.cs (3)

41public PipeWriter Input => Application.Output; 86Transport.Output.Complete(); 105Output = duplexPipe.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)

228reconnectTask = connection.NotifyOnReconnect?.Invoke(connection.Transport.Output) ?? Task.CompletedTask; 264connection.Transport.Output.Complete(connection.ApplicationTask.Exception); 515connection.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.Http.Connections.Tests (46)

HttpConnectionDispatcherTests.cs (20)

HttpConnectionManagerTests.cs (1)

128var result = await connection.Transport.Output.FlushAsync();

LongPollingTests.cs (7)

32connection.Transport.Output.Complete(); 75await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello World")); 76connection.Transport.Output.Complete(); 98await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello")); 99await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes(" ")); 100await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("World")); 102connection.Transport.Output.Complete();

ServerSentEventsTests.cs (8)

30connection.Transport.Output.Complete(); 53connection.Transport.Output.Complete(); 76await connection.Transport.Output.WriteAsync(Encoding.ASCII.GetBytes("Hello")); 77connection.Transport.Output.Complete(); 101await connection.Transport.Output.WriteAsync(Encoding.ASCII.GetBytes(hText + wText)); 102connection.Transport.Output.Complete(); 124await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes(message)); 126connection.Transport.Output.Complete();

WebSocketsTests.cs (10)

Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (1)

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

26base(duplexPipe.Input, duplexPipe.Output)

Microsoft.AspNetCore.Server.IIS (1)

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

26base(duplexPipe.Input, duplexPipe.Output)

Microsoft.AspNetCore.Server.Kestrel.Core (11)

Internal\Http\Http1Connection.cs (3)

57_context.Transport.Output, 880_context.Transport.Output.Write(Http2GoAwayHttp11RequiredBytes); 881return _context.Transport.Output.FlushAsync().GetAsTask();

Internal\Http2\Http2Connection.cs (2)

196context.Transport.Output, 593await _context.Transport.Output.WriteAsync(responseBytes);

Internal\Http3\Http3ControlStream.cs (1)

61_frameWriter.Reset(context.Transport.Output, context.ConnectionId);

Internal\Http3\Http3PendingStream.cs (1)

37Context.Transport.Output.Complete(exception);

Internal\Http3\Http3Stream.cs (1)

135_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\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)

26base(duplexPipe.Input, duplexPipe.Output)

Microsoft.AspNetCore.Server.Kestrel.Core.Tests (51)

Http1\Http1ConnectionTests.cs (39)

Http1\Http1ConnectionTestsBase.cs (2)

71_transport.Output.Complete(); 74_application.Output.Complete();

MessageBodyTests.cs (4)

1218input.Application.Output.Complete(); 1245await input.Application.Output.WriteAsync(new byte[] { 0 }); 1251input.Application.Output.Complete(); 1278input.Application.Output.Complete();

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)

32Output = new PassThroughPipeWriter(duplexPipe.Output);

StartLineTests.cs (1)

546Transport.Output.Complete();

TestHelpers\TestInput.cs (4)

68async Task Write() => await Application.Output.WriteAsync(data); 74Application.Output.Complete(); 85Application.Output.Complete(); 87Transport.Output.Complete();

Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (1)

InMemoryTransportBenchmark.cs (1)

182public PipeWriter Input => Application.Output;

Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (2)

Internal\NamedPipeConnection.cs (2)

58public PipeWriter Input => Application.Output; 283_originalTransport.Output.Complete();

Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (2)

Internal\QuicStreamContext.cs (2)

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

Microsoft.AspNetCore.Server.Kestrel.Transport.Quic.Tests (2)

QuicConnectionContextTests.cs (1)

637await serverStream.Transport.Output.CompleteAsync();

QuicTestHelpers.cs (1)

165await serverStream.Transport.Output.CompleteAsync();

Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets (2)

Internal\SocketConnection.cs (2)

71public PipeWriter Input => Application.Output; 104_originalTransport.Output.Complete();

Microsoft.AspNetCore.Shared.Tests (1)

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

26base(duplexPipe.Input, duplexPipe.Output)

Microsoft.AspNetCore.SignalR.Client.Core (5)

HubConnection.cs (4)

1213_protocol.WriteMessage(hubMessage, connectionState.Connection.Transport.Output); 1215await connectionState.Connection.Transport.Output.FlushAsync(cancellationToken).ConfigureAwait(false); 1487HandshakeProtocol.WriteRequestMessage(handshakeRequest, startingConnectionState.Connection.Transport.Output); 1489var sendHandshakeResult = await startingConnectionState.Connection.Transport.Output.FlushAsync(CancellationToken.None).ConfigureAwait(false);

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

77_writer = connection.Transport.Output;

Microsoft.AspNetCore.SignalR.Client.FunctionalTests (3)

HubProtocolVersionTests.cs (3)

142connectionContext.Transport.Output.Write(Encoding.UTF8.GetBytes(messageToken.ToString())); 143connectionContext.Transport.Output.Write(new[] { (byte)0x1e }); 144await connectionContext.Transport.Output.FlushAsync().DefaultTimeout();

Microsoft.AspNetCore.SignalR.Client.Tests (23)

HttpConnectionTests.ConnectionLifecycle.cs (1)

315await connection.Transport.Output.WriteAsync(new byte[] { 0x42 }).DefaultTimeout();

HttpConnectionTests.Transport.cs (10)

70await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello world 1")); 71await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello world 2")); 146await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello World")); 186await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello World")); 246await connection.Transport.Output.WriteAsync(data).DefaultTimeout(); 262() => connection.Transport.Output.WriteAsync(new byte[0]).DefaultTimeout()); 278() => connection.Transport.Output.WriteAsync(new byte[0]).DefaultTimeout()); 412await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello world 1")); 507await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello world 1")); 550await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello world 1"));

HubConnectionTests.ConnectionLifecycle.cs (2)

626await innerConnection.Application.Output.WriteAsync(Encoding.UTF8.GetBytes(new[] { '{' })).DefaultTimeout(); 627innerConnection.Application.Output.Complete();

HubConnectionTests.Reconnect.cs (1)

920await currentTestConnection.Application.Output.WriteAsync(output.ToArray()).DefaultTimeout();

TestConnection.cs (6)

99await Application.Output.WriteAsync(response); 109return Application.Output.WriteAsync(bytes).AsTask(); 119return Application.Output.WriteAsync(bytes).AsTask(); 161await Application.Output.CompleteAsync(); 201Application.Output.Complete(ex); 212Transport.Output.Complete();

TestTransport.cs (3)

27public PipeWriter Output => _transport.Output; 80Application.Output.Complete(); 87_transport.Output.Complete();

Microsoft.AspNetCore.SignalR.Core (9)

HubConnectionContext.cs (8)

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

77_writer = connection.Transport.Output;

Microsoft.AspNetCore.SignalR.Specification.Tests (3)

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

Microsoft.AspNetCore.SignalR.Tests (46)

AuthConnectionHandler.cs (1)

23await connection.Transport.Output.WriteAsync(buffer.ToArray());

EchoConnectionHandler.cs (1)

21await connection.Transport.Output.WriteAsync(buffer.ToArray());

EndToEndTests.cs (5)

193await connection.Transport.Output.WriteAsync(message).DefaultTimeout(); 279await connection.Transport.Output.WriteAsync(bytes).DefaultTimeout(); 336await connection.Transport.Output.WriteAsync(bytes).DefaultTimeout(); 709public PipeWriter Output => _transport.Output; 750_application.Output.Complete();

HttpHeaderConnectionHandler.cs (1)

30await connection.Transport.Output.WriteAsync(data);

HubConnectionHandlerTests.cs (28)

Internal\MessageBufferTests.cs (9)

WriteThenCloseConnectionHandler.cs (1)

19await connection.Transport.Output.WriteAsync(buffer.ToArray());

Microsoft.AspNetCore.SignalR.Tests.Utils (3)

TestClient.cs (3)

75await Connection.Application.Output.WriteAsync(GetHandshakeRequestMessage()); 236await Connection.Application.Output.WriteAsync(payload); 314Connection.Application.Output.Complete();

SignalR.Client.FunctionalTestApp (1)

EchoConnectionHandler.cs (1)

22await connection.Transport.Output.WriteAsync(buffer.ToArray());

SignalRSamples (1)

ConnectionHandlers\MessagesConnectionHandler.cs (1)

68tasks.Add(c.Transport.Output.WriteAsync(payload).AsTask());

SocialWeather (1)

PersistentConnectionLifeTimeManager.cs (1)

50await connection.Transport.Output.WriteAsync(ms.ToArray());

Sockets.FunctionalTests (2)

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)

32Output = new PassThroughPipeWriter(duplexPipe.Output);

src\Servers\Kestrel\test\FunctionalTests\UnixDomainSocketsTests.cs (1)

63await connection.Transport.Output.WriteAsync(result.Buffer.ToArray());

WebTransportInteractiveSampleApp (2)

Program.cs (2)

116var outputPipe = stream.Transport.Output; 148await stream.Transport.Output.WriteAsync(new("Created a new stream from the client and sent this message then closing the stream."u8.ToArray()));