Base:
property
Transport
Microsoft.AspNetCore.Connections.ConnectionContext.Transport
Implemented interface member:
property
Transport
Microsoft.AspNetCore.Connections.Features.IConnectionTransportFeature.Transport
2 writes to Transport
Microsoft.AspNetCore.Http.Connections (2)
Internal\HttpConnectionContext.cs (2)
71Transport = transport; 716Transport = transportToApplication;
56 references to Transport
Microsoft.AspNetCore.Http.Connections (8)
Internal\HttpConnectionContext.cs (6)
66/// The caller is expected to set the <see cref="Transport"/> and <see cref="Application"/> pipes manually. 341Transport?.Output.Complete(applicationTask.Exception?.InnerException); 342Transport?.Input.Complete(); 383Transport?.Output.Complete(); 384Transport?.Input.Complete(); 712var transportToApplication = new DuplexPipe(Transport.Input, input.Writer);
Internal\HttpConnectionDispatcher.cs (2)
228reconnectTask = connection.NotifyOnReconnect?.Invoke(connection.Transport.Output) ?? Task.CompletedTask; 264connection.Transport.Output.Complete(connection.ApplicationTask.Exception);
Microsoft.AspNetCore.Http.Connections.Tests (48)
HttpConnectionDispatcherTests.cs (17)
135await connection.Transport.Input.ConsumeAsync(5); 241await connection.Transport.Input.ConsumeAsync(10); 244Assert.True(connection.Transport.Input.TryRead(out var result)); 246connection.Transport.Input.AdvanceTo(result.Buffer.End); 612Assert.True(connection.Transport.Input.TryRead(out var result)); 615connection.Transport.Input.AdvanceTo(result.Buffer.End); 734connection.Transport.Output.Complete(); 1297await connection.Transport.Output.WriteAsync(new byte[] { 1 }).DefaultTimeout(); 1336await connection.Transport.Output.WriteAsync(new byte[] { 1 }).DefaultTimeout(); 1380await connection.Transport.Output.WriteAsync(new byte[] { 1 }).DefaultTimeout(); 1658await connection.Transport.Output.WriteAsync(buffer); 1775await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello, World")); 1863await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Unblock")).AsTask().DefaultTimeout(); 1915await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Unblock")).AsTask().DefaultTimeout(); 2747connection.Transport.Output.Complete(new InvalidOperationException()); 2833connection.Transport.Output.Complete(); 3131connection.Transport.Output.Complete();
HttpConnectionManagerTests.cs (17)
56Assert.NotNull(connection.Transport); 109var result = await connection.Transport.Input.ReadAsync(); 110connection.Transport.Input.AdvanceTo(result.Buffer.End); 128var result = await connection.Transport.Output.FlushAsync(); 134var exception = await Assert.ThrowsAsync<InvalidOperationException>(async () => await connection.Transport.Input.ReadAsync()); 164var transport = connection.Transport; 172Assert.Same(transport, newConnection.Transport); 184var transport = connection.Transport; 191Assert.Same(transport, newConnection.Transport); 206var transport = connection.Transport; 213Assert.Same(transport, newConnection.Transport); 227var transport = connection.Transport; 235Assert.Same(transport, newConnection.Transport); 251var result = await connection.Transport.Input.ReadAsync(); 259connection.Transport.Input.AdvanceTo(result.Buffer.End); 366Assert.NotNull(connection.Transport); 382Assert.NotNull(connection.Transport);
WebSocketsTests.cs (14)
54var result = await connection.Transport.Input.ReadAsync(); 57connection.Transport.Input.AdvanceTo(buffer.End); 59connection.Transport.Output.Complete(); 95await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Hello")); 96connection.Transport.Output.Complete(); 132var result = await connection.Transport.Input.ReadAsync(); 133connection.Transport.Input.AdvanceTo(result.Buffer.End); 142connection.Transport.Output.Complete(); 188connection.Transport.Output.Complete(new InvalidOperationException("Catastrophic failure.")); 222connection.Transport.Output.Complete(); 259connection.Transport.Output.Complete(new Exception()); 294connection.Transport.Output.Complete(); 335connection.Transport.Output.Complete(); 389connection.Transport.Output.Complete();