2 writes to Application
Microsoft.AspNetCore.Connections.Abstractions (1)
DefaultConnectionContext.cs (1)
68Application = application;
Microsoft.AspNetCore.SignalR.Tests (1)
HubConnectionHandlerTests.cs (1)
5292connection.Application = applicationToTransport;
51 references to Application
Microsoft.AspNetCore.Connections.Abstractions (3)
DefaultConnectionContext.cs (3)
31/// The caller is expected to set the <see cref="Transport"/> and <see cref="Application"/> pipes manually. 40/// The caller is expected to set the <see cref="Transport"/> and <see cref="Application"/> pipes manually. 63/// <param name="application">The <see cref="Application"/>.</param>
Microsoft.AspNetCore.Http.Connections.Tests (9)
LongPollingTests.cs (4)
30var poll = new LongPollingServerTransport(CancellationToken.None, connection.Application.Input, LoggerFactory); 50var poll = new LongPollingServerTransport(timeoutToken, connection.Application.Input, LoggerFactory); 71var poll = new LongPollingServerTransport(CancellationToken.None, connection.Application.Input, LoggerFactory); 94var poll = new LongPollingServerTransport(CancellationToken.None, connection.Application.Input, LoggerFactory);
ServerSentEventsTests.cs (5)
28var sse = new ServerSentEventsServerTransport(connection.Application.Input, connectionId: string.Empty, LoggerFactory); 51var sse = new ServerSentEventsServerTransport(connection.Application.Input, connectionId: connection.ConnectionId, LoggerFactory); 72var sse = new ServerSentEventsServerTransport(connection.Application.Input, connectionId: string.Empty, LoggerFactory); 94var sse = new ServerSentEventsServerTransport(connection.Application.Input, connectionId: string.Empty, LoggerFactory); 120var sse = new ServerSentEventsServerTransport(connection.Application.Input, connectionId: string.Empty, LoggerFactory);
Microsoft.AspNetCore.SignalR.Microbenchmarks (1)
BroadcastBenchmark.cs (1)
55_ = ConsumeAsync(connection.Application);
Microsoft.AspNetCore.SignalR.Specification.Tests (7)
src\SignalR\common\testassets\Tests.Utils\TestClient.cs (7)
75await Connection.Application.Output.WriteAsync(GetHandshakeRequestMessage()); 236await Connection.Application.Output.WriteAsync(payload); 248var result = await Connection.Application.Input.ReadAsync(); 265Connection.Application.Input.AdvanceTo(buffer.Start); 277if (!Connection.Application.Input.TryRead(out var result)) 304Connection.Application.Input.AdvanceTo(buffer.Start); 314Connection.Application.Output.Complete();
Microsoft.AspNetCore.SignalR.Tests (24)
HubConnectionHandlerTests.cs (24)
354await client.Connection.Application.Output.WriteAsync(part1); 358await client.Connection.Application.Output.WriteAsync(part2); 362await client.Connection.Application.Output.WriteAsync(part3); 395await client.Connection.Application.Output.WriteAsync(part1); 399await client.Connection.Application.Output.WriteAsync(part2); 403await client.Connection.Application.Output.WriteAsync(part3); 436await client.Connection.Application.Output.WriteAsync(payload); 491await client.Connection.Application.Output.WriteAsync(payload); 520await client.Connection.Application.Output.WriteAsync(payload.AsMemory(0, payload.Length / 2)); 521await client.Connection.Application.Output.WriteAsync(payload.AsMemory(payload.Length / 2)); 554client.Connection.Application.Output.Write(payload1); 555client.Connection.Application.Output.Write(payload2); 556client.Connection.Application.Output.Write(payload3); 557await client.Connection.Application.Output.FlushAsync(); 605client.Connection.Application.Output.Write(payload1); 606client.Connection.Application.Output.Write(payload2); 607client.Connection.Application.Output.Write(payload3); 608await client.Connection.Application.Output.FlushAsync(); 669await client.Connection.Application.Output.WriteAsync(payload).DefaultTimeout(); 673client.Connection.Application.Output.Complete(); 3566await client.Connection.Application.Output.WriteAsync(Encoding.UTF8.GetBytes(new[] { '{' })).DefaultTimeout(); 3569client.Connection.Application.Output.Complete(); 5285var prevPipe = connection.Application.Input; 5290var applicationToTransport = new DuplexPipe(input.Reader, connection.Application.Output);
Microsoft.AspNetCore.SignalR.Tests.Utils (7)
TestClient.cs (7)
75await Connection.Application.Output.WriteAsync(GetHandshakeRequestMessage()); 236await Connection.Application.Output.WriteAsync(payload); 248var result = await Connection.Application.Input.ReadAsync(); 265Connection.Application.Input.AdvanceTo(buffer.Start); 277if (!Connection.Application.Input.TryRead(out var result)) 304Connection.Application.Input.AdvanceTo(buffer.Start); 314Connection.Application.Output.Complete();