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)
1187public 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)
951public 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)
1187public 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)
560public 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)
235context.Transport = sslDuplexPipe; 249context.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)
610connection.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;
207 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 (5)
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));
src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)
23context.Transport = new PassThroughDuplexPipe(context.Transport);
Microsoft.AspNetCore.Http.Connections.Tests (30)
HttpConnectionDispatcherTests.cs (28)
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); 2223await c.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Message1")).DefaultTimeout(); 2226await c.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Message2")).DefaultTimeout(); 3821var result = connection.Transport.Input.ReadAsync().AsTask().Result; 3822connection.Transport.Input.AdvanceTo(result.Buffer.End); 3849var result = await connection.Transport.Input.ReadAsync(); 3866await connection.Transport.Output.WriteAsync(result.Buffer.ToArray()); 3870connection.Transport.Input.AdvanceTo(result.Buffer.End); 3888var result = await connection.Transport.Input.ReadAsync(); 3899connection.Transport.Input.AdvanceTo(result.Buffer.End); 3911var result = await connection.Transport.Input.ReadAsync(); 3918await connection.Transport.Output.WriteAsync(buffer.ToArray()); 3927connection.Transport.Input.AdvanceTo(result.Buffer.End); 3939var result = await connection.Transport.Input.ReadAsync(); 3952await connection.Transport.Output.WriteAsync(message.Buffer.ToArray()); 3956connection.Transport.Input.AdvanceTo(result.Buffer.End); 3969var result = await connection.Transport.Input.ReadAsync(); 3979await connection.Transport.Output.WriteAsync(result.Buffer.ToArray()); 3983connection.Transport.Input.AdvanceTo(result.Buffer.End); 3996var result = await connection.Transport.Input.ReadAsync(); 4006await connection.Transport.Output.WriteAsync(result.Buffer.ToArray()); 4010connection.Transport.Input.AdvanceTo(result.Buffer.End); 4024_writer = connection.Transport.Output; 4045var res = await connection.Transport.Input.ReadAsync(connection.ConnectionClosed); 4058connection.Transport.Input.AdvanceTo(res.Buffer.End);
MapConnectionHandlerTests.cs (2)
436var result = await connection.Transport.Input.ReadAsync(); 444connection.Transport.Input.AdvanceTo(result.Buffer.Start);
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 (10)
Internal\Http3\Http3Connection.cs (2)
613stream.InitializeWithExistingContext(streamContext.Transport); 675Transport = streamContext.Transport
Middleware\HttpConnectionMiddleware.cs (1)
47httpConnectionContext.Transport = connectionContext.Transport;
Middleware\HttpsConnectionMiddleware.cs (2)
152context.Transport, 231var 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)
24var input = connection.Transport.Input;
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 (87)
QuicConnectionContextTests.cs (46)
109var read = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).DefaultTimeout(); 111serverStream.Transport.Input.AdvanceTo(read.Buffer.End); 174var read = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).DefaultTimeout(); 176serverStream.Transport.Input.AdvanceTo(read.Buffer.End); 182read = await serverStream.Transport.Input.ReadAsync().DefaultTimeout(); 207await serverStream.Transport.Output.WriteAsync(TestData); 217var read = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).DefaultTimeout(); 219serverStream.Transport.Input.AdvanceTo(read.Buffer.End); 230read = await serverStream.Transport.Input.ReadAsync().DefaultTimeout(); 233await serverStream.Transport.Output.CompleteAsync(); 254await serverStream.Transport.Output.WriteAsync(TestData).DefaultTimeout(); 276await serverStream.Transport.Output.CompleteAsync().DefaultTimeout(); 331var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).DefaultTimeout(); 332serverStream.Transport.Input.AdvanceTo(readResult.Buffer.End); 335readResult = await serverStream.Transport.Input.ReadAsync(); 339await serverStream.Transport.Input.CompleteAsync(); 374var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).DefaultTimeout(); 375serverStream.Transport.Input.AdvanceTo(readResult.Buffer.End); 378readResult = await serverStream.Transport.Input.ReadAsync(); 382await serverStream.Transport.Input.CompleteAsync(); 383await serverStream.Transport.Output.CompleteAsync(); 420var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).DefaultTimeout(); 421serverStream.Transport.Input.AdvanceTo(readResult.Buffer.End); 426var ex = await Assert.ThrowsAsync<ConnectionResetException>(() => serverStream.Transport.Input.ReadAsync().AsTask()).DefaultTimeout(); 431await serverStream.Transport.Input.CompleteAsync(); 432await serverStream.Transport.Output.CompleteAsync(); 469var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).DefaultTimeout(); 470serverStream.Transport.Input.AdvanceTo(readResult.Buffer.End); 475var serverEx = await Assert.ThrowsAsync<ConnectionResetException>(() => serverStream.Transport.Input.ReadAsync().AsTask()).DefaultTimeout(); 483await serverStream.Transport.Input.CompleteAsync(); 484await serverStream.Transport.Output.CompleteAsync(); 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(); 684var readResult1 = await serverStream1.Transport.Input.ReadAtLeastAsync(TestData.Length).DefaultTimeout(); 685serverStream1.Transport.Input.AdvanceTo(readResult1.Buffer.End); 690readResult1 = await serverStream1.Transport.Input.ReadAsync(); 695await serverStream1.Transport.Input.CompleteAsync(); 696await serverStream1.Transport.Output.CompleteAsync(); 712var readResult2 = await serverStream2.Transport.Input.ReadAtLeastAsync(TestData.Length).DefaultTimeout(); 713serverStream2.Transport.Input.AdvanceTo(readResult2.Buffer.End); 718readResult2 = await serverStream2.Transport.Input.ReadAsync(); 723await serverStream2.Transport.Input.CompleteAsync(); 724await serverStream2.Transport.Output.CompleteAsync();
QuicStreamContextTests.cs (36)
70var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).DefaultTimeout(); 71serverStream.Transport.Input.AdvanceTo(readResult.Buffer.End); 76await serverStream.Transport.Output.CompleteAsync(); 82await serverStream.Transport.Input.CompleteAsync(); 123var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).DefaultTimeout(); 124serverStream.Transport.Input.AdvanceTo(readResult.Buffer.End); 128await serverStream.Transport.Output.WriteAsync(new byte[1024 * 1024 * 32]).DefaultTimeout(); 132await serverStream.Transport.Input.CompleteAsync(); 133await serverStream.Transport.Output.CompleteAsync(); 189var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).DefaultTimeout(); 190serverStream.Transport.Input.AdvanceTo(readResult.Buffer.End); 193readResult = await serverStream.Transport.Input.ReadAsync().DefaultTimeout(); 200await serverStream.Transport.Output.WriteAsync(testData).DefaultTimeout(); 203await serverStream.Transport.Input.CompleteAsync().DefaultTimeout(); 204await serverStream.Transport.Output.CompleteAsync().DefaultTimeout(); 267var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).DefaultTimeout(); 268serverStream.Transport.Input.AdvanceTo(readResult.Buffer.End); 276var ex = await Assert.ThrowsAsync<ConnectionResetException>(() => serverStream.Transport.Input.ReadAsync().AsTask()).DefaultTimeout(); 279await serverStream.Transport.Output.CompleteAsync(); 311var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).DefaultTimeout(); 312serverStream.Transport.Input.AdvanceTo(readResult.Buffer.End); 315readResult = await serverStream.Transport.Input.ReadAsync().DefaultTimeout(); 345var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).DefaultTimeout(); 346serverStream.Transport.Input.AdvanceTo(readResult.Buffer.End); 354var ex = await Assert.ThrowsAsync<ConnectionResetException>(() => serverStream.Transport.Input.ReadAsync().AsTask()).DefaultTimeout(); 384var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).DefaultTimeout(); 385serverStream.Transport.Input.AdvanceTo(readResult.Buffer.End); 387var readResultTask = serverStream.Transport.Input.ReadAsync(); 414await serverStream.Transport.Output.WriteAsync(TestData).DefaultTimeout(); 422await serverStream.Transport.Output.CompleteAsync(); 455await serverStream.Transport.Output.WriteAsync(TestData).DefaultTimeout(); 501var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).DefaultTimeout(); 502serverStream.Transport.Input.AdvanceTo(readResult.Buffer.End); 504var serverReadTask = serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).AsTask(); 513await serverStream.Transport.Output.WriteAsync(TestData).DefaultTimeout(); 515await serverStream.Transport.Output.CompleteAsync().DefaultTimeout();
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)
1219_protocol.WriteMessage(hubMessage, connectionState.Connection.Transport.Output); 1221await connectionState.Connection.Transport.Output.FlushAsync(cancellationToken).ConfigureAwait(false); 1497HandshakeProtocol.WriteRequestMessage(handshakeRequest, startingConnectionState.Connection.Transport.Output); 1499var sendHandshakeResult = await startingConnectionState.Connection.Transport.Output.FlushAsync(CancellationToken.None).ConfigureAwait(false); 1509var input = startingConnectionState.Connection.Transport.Input; 1634var input = connectionState.Connection.Transport.Input; 2267Connection.Transport.Input.CancelPendingRead(); 2392Connection.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);