1 write to Application
Microsoft.AspNetCore.Http.Connections (1)
Internal\HttpConnectionContext.cs (1)
715Application = applicationToTransport;
48 references to Application
Microsoft.AspNetCore.Http.Connections (14)
Internal\HttpConnectionContext.cs (11)
66/// The caller is expected to set the <see cref="Transport"/> and <see cref="Application"/> pipes manually. 303Application?.Output.CancelPendingFlush(); 324Application?.Output.Complete(); 331Application?.Input.CancelPendingRead(); 356Application?.Output.Complete(); 357Application?.Input.Complete(); 366Application?.Output.Complete(transportTask.Exception?.InnerException); 367Application?.Input.Complete(); 490var longPolling = new LongPollingServerTransport(timeoutSource.Token, Application.Input, loggerFactory, this); 558Application.Input.CancelPendingRead(); 713var applicationToTransport = new DuplexPipe(input.Reader, Application.Output);
Internal\HttpConnectionDispatcher.cs (3)
154var sse = new ServerSentEventsServerTransport(connection.Application.Input, connection.ConnectionId, connection, _loggerFactory); 219var ws = new WebSocketsServerTransport(options.WebSockets, connection.Application, connection, _loggerFactory); 515connection.Application.Output.Complete();
Microsoft.AspNetCore.Http.Connections.Tests (34)
HttpConnectionDispatcherTests.cs (15)
130var writeTask = connection.Application.Output.WriteAsync(new[] { (byte)'b', (byte)'y', (byte)'t', (byte)'e', (byte)'s' }); 797await connection.Application.Output.WriteAsync(buffer); 806await connection.Application.Output.WriteAsync(buffer); 808connection.Application.Output.Complete(); 1693await connection.Application.Output.WriteAsync(buffer); 1734await connection.Application.Output.WriteAsync(buffer); 2400await connection.Application.Output.WriteAsync(firstMsg); 2432await connection.Application.Output.WriteAsync(secondMsg); 2474await connection.Application.Output.WriteAsync(firstMsg); 2509await connection.Application.Output.WriteAsync(secondMsg); 2977await connection.Application.Output.WriteAsync(new byte[] { 1 }).DefaultTimeout(); 2990await connection.Application.Output.WriteAsync(new byte[] { 1 }).DefaultTimeout(); 3034await connection.Application.Output.WriteAsync(new byte[] { 1 }).DefaultTimeout(); 3045await connection.Application.Output.WriteAsync(new byte[] { 1 }).DefaultTimeout(); 3166await connection.Application.Output.WriteAsync(new byte[] { 1 }).DefaultTimeout();
HttpConnectionManagerTests.cs (10)
57Assert.NotNull(connection.Application); 90var result = await connection.Application.Input.ReadAsync(); 91connection.Application.Input.AdvanceTo(result.Buffer.End); 131result = await connection.Application.Output.FlushAsync(); 137exception = await Assert.ThrowsAsync<InvalidOperationException>(async () => await connection.Application.Input.ReadAsync()); 265var result = await connection.Application.Input.ReadAsync(); 272connection.Application.Input.AdvanceTo(result.Buffer.End); 383Assert.NotNull(connection.Application); 404var result = await connection.Application.Output.FlushAsync(); 423var result = await connection.Application.Output.FlushAsync();
WebSocketsTests.cs (9)
38var ws = new WebSocketsServerTransport(new WebSocketOptions(), connection.Application, connection, LoggerFactory); 86var ws = new WebSocketsServerTransport(new WebSocketOptions(), connection.Application, connection, LoggerFactory); 146var ws = new WebSocketsServerTransport(new WebSocketOptions(), connection.Application, connection, LoggerFactory); 179var ws = new WebSocketsServerTransport(new WebSocketOptions(), connection.Application, connection, LoggerFactory); 215var ws = new WebSocketsServerTransport(options, connection.Application, connection, LoggerFactory); 249var ws = new WebSocketsServerTransport(options, connection.Application, connection, LoggerFactory); 284var ws = new WebSocketsServerTransport(options, connection.Application, connection, LoggerFactory); 323var ws = new WebSocketsServerTransport(options, connection.Application, connection, LoggerFactory); 370var ws = new WebSocketsServerTransport(options, connection.Application, connection, LoggerFactory);