19 overrides of Transport
ClientSample (1)
Tcp\TcpConnection.cs (1)
40public override IDuplexPipe Transport { get; set; }
InMemory.FunctionalTests (2)
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (1)
1192public override IDuplexPipe Transport
src\Servers\Kestrel\shared\TransportConnection.cs (1)
40public override IDuplexPipe Transport { get; set; } = default!;
Microsoft.AspNetCore.Connections.Abstractions (1)
DefaultConnectionContext.cs (1)
87public override IDuplexPipe Transport { get; set; } = default!;
Microsoft.AspNetCore.Http.Connections (1)
Internal\HttpConnectionContext.cs (1)
201public override IDuplexPipe Transport { get; set; }
Microsoft.AspNetCore.Http.Connections.Client (1)
HttpConnection.cs (1)
56public override IDuplexPipe Transport
Microsoft.AspNetCore.Server.Kestrel.Core (3)
HttpsConfigurationService.cs (1)
195public override IDuplexPipe Transport
Internal\WebTransport\WebTransportStream.cs (1)
30public override IDuplexPipe Transport { get => _duplexPipe; set => throw new NotSupportedException(); }
Middleware\LoggingMultiplexedConnectionMiddleware.cs (1)
128public override IDuplexPipe Transport { get => _inner.Transport; set => _inner.Transport = value; }
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (1)
SniOptionsSelectorTests.cs (1)
939public override IDuplexPipe Transport { get => throw new NotImplementedException(); set => throw new NotImplementedException(); }
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (2)
src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (1)
1192public override IDuplexPipe Transport
src\Servers\Kestrel\shared\TransportConnection.cs (1)
40public override IDuplexPipe Transport { get; set; } = default!;
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (1)
src\Servers\Kestrel\shared\TransportConnection.cs (1)
40public override IDuplexPipe Transport { get; set; } = default!;
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (1)
src\Servers\Kestrel\shared\TransportConnection.cs (1)
40public override IDuplexPipe Transport { get; set; } = default!;
Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets (1)
src\Servers\Kestrel\shared\TransportConnection.cs (1)
40public override IDuplexPipe Transport { get; set; } = default!;
Microsoft.AspNetCore.SignalR.Client.Tests (2)
HubConnectionTests.Reconnect.cs (1)
1179public override IDuplexPipe Transport { get => _inner.Transport; set => _inner.Transport = value; }
TestConnection.cs (1)
39public override IDuplexPipe Transport { get; set; }
Microsoft.AspNetCore.SignalR.Microbenchmarks (1)
Shared\TestConnectionContext.cs (1)
15public override IDuplexPipe Transport { get; set; }
Microsoft.AspNetCore.SignalR.Tests (1)
Internal\MessageBufferTests.cs (1)
503public override IDuplexPipe Transport { get; set; }
29 writes to Transport
http2cat (2)
src\Shared\Http2cat\Http2CatHostedService.cs (2)
94context.Transport = sslDuplexPipe; 124context.Transport = originalTransport;
IIS.FunctionalTests (2)
src\Shared\Http2cat\Http2CatHostedService.cs (2)
94context.Transport = sslDuplexPipe; 124context.Transport = originalTransport;
IIS.LongTests (2)
src\Shared\Http2cat\Http2CatHostedService.cs (2)
94context.Transport = sslDuplexPipe; 124context.Transport = originalTransport;
IIS.NewHandler.FunctionalTests (2)
src\Shared\Http2cat\Http2CatHostedService.cs (2)
94context.Transport = sslDuplexPipe; 124context.Transport = originalTransport;
IIS.NewShim.FunctionalTests (2)
src\Shared\Http2cat\Http2CatHostedService.cs (2)
94context.Transport = sslDuplexPipe; 124context.Transport = originalTransport;
IISExpress.FunctionalTests (2)
src\Shared\Http2cat\Http2CatHostedService.cs (2)
94context.Transport = sslDuplexPipe; 124context.Transport = originalTransport;
InMemory.FunctionalTests (5)
ConnectionMiddlewareTests.cs (4)
350context.Transport = duplexPipe; 356context.Transport = old; 383context.Transport = duplexPipe; 389context.Transport = old;
src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)
23context.Transport = new PassThroughDuplexPipe(context.Transport);
Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (2)
src\Shared\Http2cat\Http2CatHostedService.cs (2)
94context.Transport = sslDuplexPipe; 124context.Transport = originalTransport;
Microsoft.AspNetCore.Server.Kestrel.Core (5)
Middleware\HttpsConnectionMiddleware.cs (2)
222context.Transport = sslDuplexPipe; 236context.Transport = originalTransport;
Middleware\LoggingConnectionMiddleware.cs (2)
28context.Transport = loggingDuplexPipe; 35context.Transport = oldTransport;
Middleware\LoggingMultiplexedConnectionMiddleware.cs (1)
128public override IDuplexPipe Transport { get => _inner.Transport; set => _inner.Transport = value; }
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (1)
src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)
23context.Transport = new PassThroughDuplexPipe(context.Transport);
Microsoft.AspNetCore.SignalR.Client.Tests (1)
HubConnectionTests.Reconnect.cs (1)
1179public override IDuplexPipe Transport { get => _inner.Transport; set => _inner.Transport = value; }
Microsoft.AspNetCore.SignalR.Tests (1)
Internal\MessageBufferTests.cs (1)
553connection.Transport = duplexPipePair.Transport;
Sockets.FunctionalTests (2)
src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)
23context.Transport = new PassThroughDuplexPipe(context.Transport);
src\Servers\Kestrel\test\FunctionalTests\ConnectionMiddlewareTests.cs (1)
60context.Transport = mockDuplexPipe;
179 references to Transport
http2cat (3)
src\Shared\Http2cat\Http2CatHostedService.cs (2)
80var originalTransport = context.Transport; 90var sslDuplexPipe = new SslDuplexPipe(context.Transport, inputPipeOptions, outputPipeOptions);
src\Shared\Http2cat\Http2Utilities.cs (1)
138_pair = new DuplexPipe.DuplexPipePair(transport: null, application: clientConnectionContext.Transport);
IIS.FunctionalTests (3)
src\Shared\Http2cat\Http2CatHostedService.cs (2)
80var originalTransport = context.Transport; 90var sslDuplexPipe = new SslDuplexPipe(context.Transport, inputPipeOptions, outputPipeOptions);
src\Shared\Http2cat\Http2Utilities.cs (1)
138_pair = new DuplexPipe.DuplexPipePair(transport: null, application: clientConnectionContext.Transport);
IIS.LongTests (3)
src\Shared\Http2cat\Http2CatHostedService.cs (2)
80var originalTransport = context.Transport; 90var sslDuplexPipe = new SslDuplexPipe(context.Transport, inputPipeOptions, outputPipeOptions);
src\Shared\Http2cat\Http2Utilities.cs (1)
138_pair = new DuplexPipe.DuplexPipePair(transport: null, application: clientConnectionContext.Transport);
IIS.NewHandler.FunctionalTests (3)
src\Shared\Http2cat\Http2CatHostedService.cs (2)
80var originalTransport = context.Transport; 90var sslDuplexPipe = new SslDuplexPipe(context.Transport, inputPipeOptions, outputPipeOptions);
src\Shared\Http2cat\Http2Utilities.cs (1)
138_pair = new DuplexPipe.DuplexPipePair(transport: null, application: clientConnectionContext.Transport);
IIS.NewShim.FunctionalTests (3)
src\Shared\Http2cat\Http2CatHostedService.cs (2)
80var originalTransport = context.Transport; 90var sslDuplexPipe = new SslDuplexPipe(context.Transport, inputPipeOptions, outputPipeOptions);
src\Shared\Http2cat\Http2Utilities.cs (1)
138_pair = new DuplexPipe.DuplexPipePair(transport: null, application: clientConnectionContext.Transport);
IISExpress.FunctionalTests (3)
src\Shared\Http2cat\Http2CatHostedService.cs (2)
80var originalTransport = context.Transport; 90var sslDuplexPipe = new SslDuplexPipe(context.Transport, inputPipeOptions, outputPipeOptions);
src\Shared\Http2cat\Http2Utilities.cs (1)
138_pair = new DuplexPipe.DuplexPipePair(transport: null, application: clientConnectionContext.Transport);
InMemory.FunctionalTests (8)
ConnectionMiddlewareTests.cs (4)
342var old = context.Transport; 343var duplexPipe = new DuplexPipeStreamAdapter<RewritingStream>(context.Transport, s => new RewritingStream(s)); 376var old = context.Transport; 377var duplexPipe = new DuplexPipeStreamAdapter<RewritingStream>(context.Transport, s => new RewritingStream(s));
Http3\WebTransport\WebTransportStreamTests.cs (3)
42await stream.Transport.Output.WriteAsync(input, CancellationToken.None); 44await stream.Transport.Output.FlushAsync(); 47var length = await stream.Transport.Input.AsStream().ReadAsync(memoryOut, CancellationToken.None);
src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)
23context.Transport = new PassThroughDuplexPipe(context.Transport);
Microsoft.AspNetCore.Http.Connections.Tests (75)
HttpConnectionDispatcherTests.cs (42)
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); 479var result = await connectionContext.Transport.Input.ReadAsync(); 481await connectionContext.Transport.Output.WriteAsync(result.Buffer.First); 543var result = await connectionContext.Transport.Input.ReadAsync(); 545await connectionContext.Transport.Output.WriteAsync(result.Buffer.First); 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(); 2223await c.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Message1")).DefaultTimeout(); 2226await c.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Message2")).DefaultTimeout(); 2747connection.Transport.Output.Complete(new InvalidOperationException()); 2833connection.Transport.Output.Complete(); 3131connection.Transport.Output.Complete(); 3817var result = connection.Transport.Input.ReadAsync().AsTask().Result; 3818connection.Transport.Input.AdvanceTo(result.Buffer.End); 3845var result = await connection.Transport.Input.ReadAsync(); 3862await connection.Transport.Output.WriteAsync(result.Buffer.ToArray()); 3866connection.Transport.Input.AdvanceTo(result.Buffer.End); 3884var result = await connection.Transport.Input.ReadAsync(); 3895connection.Transport.Input.AdvanceTo(result.Buffer.End); 3907var result = await connection.Transport.Input.ReadAsync(); 3920await connection.Transport.Output.WriteAsync(message.Buffer.ToArray()); 3924connection.Transport.Input.AdvanceTo(result.Buffer.End); 3937var result = await connection.Transport.Input.ReadAsync(); 3947await connection.Transport.Output.WriteAsync(result.Buffer.ToArray()); 3951connection.Transport.Input.AdvanceTo(result.Buffer.End); 3964var result = await connection.Transport.Input.ReadAsync(); 3974await connection.Transport.Output.WriteAsync(result.Buffer.ToArray()); 3978connection.Transport.Input.AdvanceTo(result.Buffer.End); 3992_writer = connection.Transport.Output; 4013var res = await connection.Transport.Input.ReadAsync(connection.ConnectionClosed); 4026connection.Transport.Input.AdvanceTo(res.Buffer.End);
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);
MapConnectionHandlerTests.cs (2)
436var result = await connection.Transport.Input.ReadAsync(); 444connection.Transport.Input.AdvanceTo(result.Buffer.Start);
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();
Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (3)
src\Shared\Http2cat\Http2CatHostedService.cs (2)
80var originalTransport = context.Transport; 90var sslDuplexPipe = new SslDuplexPipe(context.Transport, inputPipeOptions, outputPipeOptions);
src\Shared\Http2cat\Http2Utilities.cs (1)
138_pair = new DuplexPipe.DuplexPipePair(transport: null, application: clientConnectionContext.Transport);
Microsoft.AspNetCore.Server.Kestrel.Core (9)
Internal\Http3\Http3Connection.cs (2)
613stream.InitializeWithExistingContext(streamContext.Transport); 675Transport = streamContext.Transport
Middleware\HttpConnectionMiddleware.cs (1)
47httpConnectionContext.Transport = connectionContext.Transport;
Middleware\HttpsConnectionMiddleware.cs (2)
143context.Transport, 218var originalTransport = context.Transport;
Middleware\LoggingConnectionMiddleware.cs (2)
22var oldTransport = context.Transport; 26await using (var loggingDuplexPipe = new LoggingDuplexPipe(context.Transport, _logger))
Middleware\LoggingMultiplexedConnectionMiddleware.cs (2)
97_loggingPipe = new LoggingDuplexPipe(_inner.Transport, _logger); 128public override IDuplexPipe Transport { get => _inner.Transport; set => _inner.Transport = value; }
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (1)
src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)
23context.Transport = new PassThroughDuplexPipe(context.Transport);
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic.Tests (12)
QuicConnectionContextTests.cs (7)
109var read = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).DefaultTimeout(); 111serverStream.Transport.Input.AdvanceTo(read.Buffer.End); 612var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).DefaultTimeout(); 613serverStream.Transport.Input.AdvanceTo(readResult.Buffer.End); 617readResult = await serverStream.Transport.Input.ReadAsync(); 636await serverStream.Transport.Input.CompleteAsync(); 637await serverStream.Transport.Output.CompleteAsync();
QuicTestHelpers.cs (5)
155var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).DefaultTimeout(); 156serverStream.Transport.Input.AdvanceTo(readResult.Buffer.End); 159readResult = await serverStream.Transport.Input.ReadAsync(); 164await serverStream.Transport.Input.CompleteAsync(); 165await serverStream.Transport.Output.CompleteAsync();
Microsoft.AspNetCore.SignalR.Client.Core (9)
HubConnection.cs (8)
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); 1499var input = startingConnectionState.Connection.Transport.Input; 1624var input = connectionState.Connection.Transport.Input; 2257Connection.Transport.Input.CancelPendingRead(); 2382Connection.Transport.Input.CancelPendingRead();
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 (1)
HubConnectionTests.Reconnect.cs (1)
1179public override IDuplexPipe Transport { get => _inner.Transport; set => _inner.Transport = value; }
Microsoft.AspNetCore.SignalR.Core (10)
HubConnectionContext.cs (9)
159internal PipeReader Input => _connectionContext.Transport.Input; 280Protocol.WriteMessage(message, _connectionContext.Transport.Output); 282return _connectionContext.Transport.Output.FlushAsync(cancellationToken); 310return _connectionContext.Transport.Output.WriteAsync(buffer, cancellationToken); 418await _connectionContext.Transport.Output.WriteAsync(_cachedPingMessage); 442_connectionContext.Transport.Output.Write(HandshakeProtocol.GetSuccessfulHandshake(Protocol)); 446HandshakeProtocol.WriteResponseMessage(message, _connectionContext.Transport.Output); 449await _connectionContext.Transport.Output.FlushAsync(); 478_connectionContext.Transport.Output.CancelPendingFlush();
src\SignalR\common\Shared\MessageBuffer.cs (1)
77_writer = connection.Transport.Output;
Microsoft.AspNetCore.SignalR.Tests (12)
AuthConnectionHandler.cs (3)
18var result = await connection.Transport.Input.ReadAsync(); 23await connection.Transport.Output.WriteAsync(buffer.ToArray()); 30connection.Transport.Input.AdvanceTo(buffer.End);
EchoConnectionHandler.cs (3)
16var result = await connection.Transport.Input.ReadAsync(); 21await connection.Transport.Output.WriteAsync(buffer.ToArray()); 28connection.Transport.Input.AdvanceTo(buffer.End);
HttpHeaderConnectionHandler.cs (3)
18var result = await connection.Transport.Input.ReadAsync(); 30await connection.Transport.Output.WriteAsync(data); 34connection.Transport.Input.AdvanceTo(buffer.End);
WriteThenCloseConnectionHandler.cs (3)
14var result = await connection.Transport.Input.ReadAsync(); 19await connection.Transport.Output.WriteAsync(buffer.ToArray()); 22connection.Transport.Input.AdvanceTo(buffer.End);
SignalR.Client.FunctionalTestApp (3)
EchoConnectionHandler.cs (3)
15var result = await connection.Transport.Input.ReadAsync(); 22await connection.Transport.Output.WriteAsync(buffer.ToArray()); 31connection.Transport.Input.AdvanceTo(result.Buffer.End);
SignalRSamples (3)
ConnectionHandlers\MessagesConnectionHandler.cs (3)
27var result = await connection.Transport.Input.ReadAsync(); 46connection.Transport.Input.AdvanceTo(buffer.End); 68tasks.Add(c.Transport.Output.WriteAsync(payload).AsTask());
SocialWeather (3)
PersistentConnectionLifeTimeManager.cs (1)
50await connection.Transport.Output.WriteAsync(ms.ToArray());
SocialWeatherConnectionHandler.cs (2)
37var result = await connection.Transport.Input.ReadAsync(); 57connection.Transport.Input.AdvanceTo(buffer.End);
Sockets.FunctionalTests (4)
src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)
23context.Transport = new PassThroughDuplexPipe(context.Transport);
src\Servers\Kestrel\test\FunctionalTests\UnixDomainSocketsTests.cs (3)
55var result = await connection.Transport.Input.ReadAsync(notificationFeature.ConnectionClosedRequested); 63await connection.Transport.Output.WriteAsync(result.Buffer.ToArray()); 65connection.Transport.Input.AdvanceTo(result.Buffer.End);
WebTransportInteractiveSampleApp (4)
Program.cs (4)
95var inputPipe = stream.Transport.Input; 115var inputPipe = stream.Transport.Input; 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()));
WebTransportSampleApp (1)
Program.cs (1)
38var test = await stream.Transport.Input.AsStream().ReadAsync(memory, CancellationToken.None);