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