Transport

6 overrides of Transport

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.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.Transport.Quic (1)

src\aspnetcore\src\Servers\Kestrel\shared\TransportConnection.cs (1)

40public override IDuplexPipe Transport { get; set; } = default!;

5 writes to Transport

Microsoft.AspNetCore.Server.Kestrel.Core (5)

Middleware\HttpsConnectionMiddleware.cs (2)

243context.Transport = sslDuplexPipe; 266context.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; }

20 references to Transport

Microsoft.AspNetCore.Server.Kestrel.Core (10)

Internal\Http3\Http3Connection.cs (2)

628reusableStream.InitializeWithExistingContext(streamContext.Transport); 690Transport = streamContext.Transport

Middleware\HttpConnectionMiddleware.cs (1)

47httpConnectionContext.Transport = connectionContext.Transport;

Middleware\HttpsConnectionMiddleware.cs (2)

154context.Transport, 239var 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; }

Middleware\TlsListener.cs (1)

27var input = connection.Transport.Input;

Microsoft.AspNetCore.SignalR.Core (10)

HubConnectionContext.cs (9)

159internal PipeReader Input => _connectionContext.Transport.Input; 298Protocol.WriteMessage(message, _connectionContext.Transport.Output); 300return _connectionContext.Transport.Output.FlushAsync(cancellationToken); 338return _connectionContext.Transport.Output.WriteAsync(buffer, cancellationToken); 455await _connectionContext.Transport.Output.WriteAsync(_cachedPingMessage); 479_connectionContext.Transport.Output.Write(HandshakeProtocol.GetSuccessfulHandshake(Protocol)); 483HandshakeProtocol.WriteResponseMessage(message, _connectionContext.Transport.Output); 486await _connectionContext.Transport.Output.FlushAsync(); 515_connectionContext.Transport.Output.CancelPendingFlush();

src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (1)

78_writer = connection.Transport.Output;