IDuplexPipe

Internal\ITransport.cs (1)

12internal interface ITransport : IDuplexPipe

src\SignalR\common\Shared\DuplexPipe.cs (1)

6internal sealed class DuplexPipe : IDuplexPipe

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)

15internal class DuplexPipeStreamAdapter<TStream> : DuplexPipeStream, IDuplexPipe where TStream : Stream

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)

15internal class DuplexPipeStreamAdapter<TStream> : DuplexPipeStream, IDuplexPipe where TStream : Stream

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)

15internal class DuplexPipeStreamAdapter<TStream> : DuplexPipeStream, IDuplexPipe where TStream : Stream

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)

15internal class DuplexPipeStreamAdapter<TStream> : DuplexPipeStream, IDuplexPipe where TStream : Stream

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)

15internal class DuplexPipeStreamAdapter<TStream> : DuplexPipeStream, IDuplexPipe where TStream : Stream

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)

15internal class DuplexPipeStreamAdapter<TStream> : DuplexPipeStream, IDuplexPipe where TStream : Stream

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)

15internal class DuplexPipeStreamAdapter<TStream> : DuplexPipeStream, IDuplexPipe where TStream : Stream

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)

27private class PassThroughDuplexPipe : IDuplexPipe

TestTransport\InMemoryTransportConnection.cs (1)

96private class ObservableDuplexPipe : IDuplexPipe

src\SignalR\common\Shared\DuplexPipe.cs (1)

6internal sealed class DuplexPipe : IDuplexPipe

src\SignalR\common\Shared\DuplexPipe.cs (1)

6internal sealed class DuplexPipe : IDuplexPipe

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)

15internal class DuplexPipeStreamAdapter<TStream> : DuplexPipeStream, IDuplexPipe where TStream : Stream

src\Shared\ServerInfrastructure\DuplexPipe.cs (1)

19internal sealed class DuplexPipe : IDuplexPipe

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)

15internal class DuplexPipeStreamAdapter<TStream> : DuplexPipeStream, IDuplexPipe where TStream : Stream

src\Shared\ServerInfrastructure\DuplexPipe.cs (1)

19internal sealed class DuplexPipe : IDuplexPipe

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)

15internal class DuplexPipeStreamAdapter<TStream> : DuplexPipeStream, IDuplexPipe where TStream : Stream

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)

27private class PassThroughDuplexPipe : IDuplexPipe

Mocks\MockDuplexPipe.cs (1)

8internal sealed class MockDuplexPipe : IDuplexPipe

src\Shared\ServerInfrastructure\DuplexPipe.cs (1)

19internal sealed class DuplexPipe : IDuplexPipe

src\Shared\ServerInfrastructure\DuplexPipe.cs (1)

19internal sealed class DuplexPipe : IDuplexPipe

src\Shared\ServerInfrastructure\DuplexPipe.cs (1)

19internal sealed class DuplexPipe : IDuplexPipe

src\Shared\ServerInfrastructure\DuplexPipe.cs (1)

19internal sealed class DuplexPipe : IDuplexPipe

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)

15internal class DuplexPipeStreamAdapter<TStream> : DuplexPipeStream, IDuplexPipe where TStream : Stream

Shared\TestDuplexPipe.cs (1)

8public class TestDuplexPipe : IDuplexPipe

src\SignalR\common\Shared\DuplexPipe.cs (1)

6internal sealed class DuplexPipe : IDuplexPipe

HubConnectionHandlerTests.cs (1)

2988internal class CustomDuplex : IDuplexPipe

Internal\MessageBufferTests.cs (1)

506internal sealed class DuplexPipe : IDuplexPipe

src\SignalR\common\Shared\DuplexPipe.cs (1)

6internal sealed class DuplexPipe : IDuplexPipe

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)

27private class PassThroughDuplexPipe : IDuplexPipe

src\Servers\Kestrel\test\FunctionalTests\ConnectionMiddlewareTests.cs (1)

80private class MockDuplexPipe : IDuplexPipe

src\SignalR\common\Shared\DuplexPipe.cs (4)

32public IDuplexPipe Transport { get; } 33public IDuplexPipe Application { get; } 35public DuplexPipePair(IDuplexPipe transport, IDuplexPipe application)

Tcp\TcpConnection.cs (2)

23private IDuplexPipe _application; 40public override IDuplexPipe Transport { get; set; }

src\Shared\Http2cat\Http2CatHostedService.cs (1)

80var originalTransport = context.Transport;

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (3)

12/// A helper for wrapping a Stream decorator from an <see cref="IDuplexPipe"/>. 20public DuplexPipeStreamAdapter(IDuplexPipe duplexPipe, Func<Stream, TStream> createStream) : 25public DuplexPipeStreamAdapter(IDuplexPipe duplexPipe, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions, Func<Stream, TStream> createStream) :

src\Shared\ServerInfrastructure\SslDuplexPipe.cs (2)

14public SslDuplexPipe(IDuplexPipe transport, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions) 19public SslDuplexPipe(IDuplexPipe transport, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions, Func<Stream, SslStream> factory) :

src\Shared\Http2cat\Http2CatHostedService.cs (1)

80var originalTransport = context.Transport;

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (3)

12/// A helper for wrapping a Stream decorator from an <see cref="IDuplexPipe"/>. 20public DuplexPipeStreamAdapter(IDuplexPipe duplexPipe, Func<Stream, TStream> createStream) : 25public DuplexPipeStreamAdapter(IDuplexPipe duplexPipe, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions, Func<Stream, TStream> createStream) :

src\Shared\ServerInfrastructure\SslDuplexPipe.cs (2)

14public SslDuplexPipe(IDuplexPipe transport, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions) 19public SslDuplexPipe(IDuplexPipe transport, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions, Func<Stream, SslStream> factory) :

src\Shared\Http2cat\Http2CatHostedService.cs (1)

80var originalTransport = context.Transport;

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (3)

12/// A helper for wrapping a Stream decorator from an <see cref="IDuplexPipe"/>. 20public DuplexPipeStreamAdapter(IDuplexPipe duplexPipe, Func<Stream, TStream> createStream) : 25public DuplexPipeStreamAdapter(IDuplexPipe duplexPipe, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions, Func<Stream, TStream> createStream) :

src\Shared\ServerInfrastructure\SslDuplexPipe.cs (2)

14public SslDuplexPipe(IDuplexPipe transport, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions) 19public SslDuplexPipe(IDuplexPipe transport, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions, Func<Stream, SslStream> factory) :

src\Shared\Http2cat\Http2CatHostedService.cs (1)

80var originalTransport = context.Transport;

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (3)

12/// A helper for wrapping a Stream decorator from an <see cref="IDuplexPipe"/>. 20public DuplexPipeStreamAdapter(IDuplexPipe duplexPipe, Func<Stream, TStream> createStream) : 25public DuplexPipeStreamAdapter(IDuplexPipe duplexPipe, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions, Func<Stream, TStream> createStream) :

src\Shared\ServerInfrastructure\SslDuplexPipe.cs (2)

14public SslDuplexPipe(IDuplexPipe transport, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions) 19public SslDuplexPipe(IDuplexPipe transport, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions, Func<Stream, SslStream> factory) :

src\Shared\Http2cat\Http2CatHostedService.cs (1)

80var originalTransport = context.Transport;

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (3)

12/// A helper for wrapping a Stream decorator from an <see cref="IDuplexPipe"/>. 20public DuplexPipeStreamAdapter(IDuplexPipe duplexPipe, Func<Stream, TStream> createStream) : 25public DuplexPipeStreamAdapter(IDuplexPipe duplexPipe, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions, Func<Stream, TStream> createStream) :

src\Shared\ServerInfrastructure\SslDuplexPipe.cs (2)

14public SslDuplexPipe(IDuplexPipe transport, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions) 19public SslDuplexPipe(IDuplexPipe transport, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions, Func<Stream, SslStream> factory) :

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (3)

12/// A helper for wrapping a Stream decorator from an <see cref="IDuplexPipe"/>. 20public DuplexPipeStreamAdapter(IDuplexPipe duplexPipe, Func<Stream, TStream> createStream) : 25public DuplexPipeStreamAdapter(IDuplexPipe duplexPipe, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions, Func<Stream, TStream> createStream) :

src\Shared\ServerInfrastructure\SslDuplexPipe.cs (2)

14public SslDuplexPipe(IDuplexPipe transport, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions) 19public SslDuplexPipe(IDuplexPipe transport, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions, Func<Stream, SslStream> factory) :

src\Shared\Http2cat\Http2CatHostedService.cs (1)

80var originalTransport = context.Transport;

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (3)

12/// A helper for wrapping a Stream decorator from an <see cref="IDuplexPipe"/>. 20public DuplexPipeStreamAdapter(IDuplexPipe duplexPipe, Func<Stream, TStream> createStream) : 25public DuplexPipeStreamAdapter(IDuplexPipe duplexPipe, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions, Func<Stream, TStream> createStream) :

src\Shared\ServerInfrastructure\SslDuplexPipe.cs (2)

14public SslDuplexPipe(IDuplexPipe transport, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions) 19public SslDuplexPipe(IDuplexPipe transport, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions, Func<Stream, SslStream> factory) :

ConnectionMiddlewareTests.cs (2)

342var old = context.Transport; 376var old = context.Transport;

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (1)

1192public override IDuplexPipe Transport

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)

29public PassThroughDuplexPipe(IDuplexPipe duplexPipe)

src\Servers\Kestrel\shared\test\TestContextFactory.cs (2)

51IDuplexPipe transport, 185IDuplexPipe transport = null,

src\Servers\Kestrel\shared\TransportConnection.cs (2)

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

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

21IDuplexPipe IConnectionTransportFeature.Transport

TestTransport\InMemoryTransportConnection.cs (1)

100public ObservableDuplexPipe(IDuplexPipe duplexPipe)

ConnectionContext.cs (2)

16/// Gets or sets the <see cref="IDuplexPipe"/> that can be used to read or write data on this connection. 18public abstract IDuplexPipe Transport { get; set; }

DefaultConnectionContext.cs (4)

64public DefaultConnectionContext(string id, IDuplexPipe transport, IDuplexPipe application) 84public IDuplexPipe? Application { get; set; } 87public override IDuplexPipe Transport { get; set; } = default!;

Features\IConnectionTransportFeature.cs (1)

16IDuplexPipe Transport { get; set; }

Internal\HttpConnectionContext.cs (5)

46private IDuplexPipe _application; 69IDuplexPipe transport, IDuplexPipe application, HttpConnectionDispatcherOptions options, bool useStatefulReconnect) 189public IDuplexPipe Application 201public override IDuplexPipe Transport { get; set; }

Internal\Transports\WebSocketsServerTransport.cs (2)

16private readonly IDuplexPipe _application; 23public WebSocketsServerTransport(WebSocketOptions options, IDuplexPipe application, HttpConnectionContext connection, ILoggerFactory loggerFactory)

src\SignalR\common\Shared\DuplexPipe.cs (4)

32public IDuplexPipe Transport { get; } 33public IDuplexPipe Application { get; } 35public DuplexPipePair(IDuplexPipe transport, IDuplexPipe application)

HttpConnection.cs (1)

56public override IDuplexPipe Transport

Internal\LongPollingTransport.cs (2)

23private IDuplexPipe? _application; 24private IDuplexPipe? _transport;

Internal\SendUtils.cs (1)

19public static async Task SendMessages(Uri sendUrl, IDuplexPipe application, HttpClient httpClient, ILogger logger, CancellationToken cancellationToken = default)

Internal\ServerSentEventsTransport.cs (2)

28private IDuplexPipe? _transport; 29private IDuplexPipe? _application;

Internal\WebSocketsTransport.cs (2)

33private IDuplexPipe? _application; 43private IDuplexPipe? _transport;

src\SignalR\common\Shared\DuplexPipe.cs (4)

32public IDuplexPipe Transport { get; } 33public IDuplexPipe Application { get; } 35public DuplexPipePair(IDuplexPipe transport, IDuplexPipe application)

HttpConnectionManagerTests.cs (4)

164var transport = connection.Transport; 184var transport = connection.Transport; 206var transport = connection.Transport; 227var transport = connection.Transport;

src\Shared\Http2cat\Http2CatHostedService.cs (1)

80var originalTransport = context.Transport;

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (3)

12/// A helper for wrapping a Stream decorator from an <see cref="IDuplexPipe"/>. 20public DuplexPipeStreamAdapter(IDuplexPipe duplexPipe, Func<Stream, TStream> createStream) : 25public DuplexPipeStreamAdapter(IDuplexPipe duplexPipe, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions, Func<Stream, TStream> createStream) :

src\Shared\ServerInfrastructure\SslDuplexPipe.cs (2)

14public SslDuplexPipe(IDuplexPipe transport, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions) 19public SslDuplexPipe(IDuplexPipe transport, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions, Func<Stream, SslStream> factory) :

src\Shared\ServerInfrastructure\DuplexPipe.cs (7)

9/// An <see cref="IDuplexPipe"/> is *not* a pipe. It is also a reader-writer pair, but the reader and writer are not 14/// A <see cref="DuplexPipePair"/> is a pair of <see cref="IDuplexPipe"/> instances, each of which represents one end of 16/// <see cref="Pipe"/>s, as these underlie the <see cref="IDuplexPipe"/> instances. In either view, it is composed of 45public IDuplexPipe Transport { get; } 46public IDuplexPipe Application { get; } 48public DuplexPipePair(IDuplexPipe transport, IDuplexPipe application)

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (3)

12/// A helper for wrapping a Stream decorator from an <see cref="IDuplexPipe"/>. 20public DuplexPipeStreamAdapter(IDuplexPipe duplexPipe, Func<Stream, TStream> createStream) : 25public DuplexPipeStreamAdapter(IDuplexPipe duplexPipe, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions, Func<Stream, TStream> createStream) :

src\Shared\ServerInfrastructure\SslDuplexPipe.cs (2)

14public SslDuplexPipe(IDuplexPipe transport, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions) 19public SslDuplexPipe(IDuplexPipe transport, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions, Func<Stream, SslStream> factory) :

HttpsConfigurationService.cs (1)

195public override IDuplexPipe Transport

Internal\Http3\Http3Stream.cs (1)

138public void InitializeWithExistingContext(IDuplexPipe transport)

Internal\HttpConnectionContext.cs (1)

29public IDuplexPipe Transport { get; set; } = default!;

Internal\WebTransport\WebTransportStream.cs (1)

30public override IDuplexPipe Transport { get => _duplexPipe; set => throw new NotSupportedException(); }

Middleware\HttpsConnectionMiddleware.cs (2)

218var originalTransport = context.Transport; 419private SslDuplexPipe CreateSslDuplexPipe(IDuplexPipe transport, MemoryPool<byte> memoryPool)

Middleware\LoggingConnectionMiddleware.cs (1)

22var oldTransport = context.Transport;

Middleware\LoggingDuplexPipe.cs (1)

14public LoggingDuplexPipe(IDuplexPipe transport, ILogger logger) :

Middleware\LoggingMultiplexedConnectionMiddleware.cs (1)

128public override IDuplexPipe Transport { get => _inner.Transport; set => _inner.Transport = value; }

src\Shared\ServerInfrastructure\DuplexPipe.cs (7)

9/// An <see cref="IDuplexPipe"/> is *not* a pipe. It is also a reader-writer pair, but the reader and writer are not 14/// A <see cref="DuplexPipePair"/> is a pair of <see cref="IDuplexPipe"/> instances, each of which represents one end of 16/// <see cref="Pipe"/>s, as these underlie the <see cref="IDuplexPipe"/> instances. In either view, it is composed of 45public IDuplexPipe Transport { get; } 46public IDuplexPipe Application { get; } 48public DuplexPipePair(IDuplexPipe transport, IDuplexPipe application)

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (3)

12/// A helper for wrapping a Stream decorator from an <see cref="IDuplexPipe"/>. 20public DuplexPipeStreamAdapter(IDuplexPipe duplexPipe, Func<Stream, TStream> createStream) : 25public DuplexPipeStreamAdapter(IDuplexPipe duplexPipe, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions, Func<Stream, TStream> createStream) :

src\Shared\ServerInfrastructure\SslDuplexPipe.cs (2)

14public SslDuplexPipe(IDuplexPipe transport, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions) 19public SslDuplexPipe(IDuplexPipe transport, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions, Func<Stream, SslStream> factory) :

Http1\Http1ConnectionTestsBase.cs (2)

20internal IDuplexPipe _transport; 21internal IDuplexPipe _application;

Http1\Http1HttpProtocolFeatureCollectionTests.cs (1)

38transport: Mock.Of<IDuplexPipe>(),

SniOptionsSelectorTests.cs (1)

939public override IDuplexPipe Transport { get => throw new NotImplementedException(); set => throw new NotImplementedException(); }

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)

29public PassThroughDuplexPipe(IDuplexPipe duplexPipe)

src\Servers\Kestrel\shared\test\TestContextFactory.cs (2)

51IDuplexPipe transport, 185IDuplexPipe transport = null,

StartLineTests.cs (1)

20private IDuplexPipe Transport { get; }

TestHelpers\TestInput.cs (2)

57public IDuplexPipe Transport { get; } 59public IDuplexPipe Application { get; }

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (1)

1192public override IDuplexPipe Transport

src\Servers\Kestrel\shared\test\TestContextFactory.cs (2)

51IDuplexPipe transport, 185IDuplexPipe transport = null,

src\Servers\Kestrel\shared\TransportConnection.cs (2)

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

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

21IDuplexPipe IConnectionTransportFeature.Transport

Internal\NamedPipeConnection.cs (1)

21private readonly IDuplexPipe _originalTransport;

src\Servers\Kestrel\shared\TransportConnection.cs (2)

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

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

21IDuplexPipe IConnectionTransportFeature.Transport

src\Shared\ServerInfrastructure\DuplexPipe.cs (7)

9/// An <see cref="IDuplexPipe"/> is *not* a pipe. It is also a reader-writer pair, but the reader and writer are not 14/// A <see cref="DuplexPipePair"/> is a pair of <see cref="IDuplexPipe"/> instances, each of which represents one end of 16/// <see cref="Pipe"/>s, as these underlie the <see cref="IDuplexPipe"/> instances. In either view, it is composed of 45public IDuplexPipe Transport { get; } 46public IDuplexPipe Application { get; } 48public DuplexPipePair(IDuplexPipe transport, IDuplexPipe application)

Internal\QuicStreamContext.cs (2)

28private readonly IDuplexPipe _originalTransport; 29private readonly IDuplexPipe _originalApplication;

src\Servers\Kestrel\shared\TransportConnection.cs (2)

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

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

21IDuplexPipe IConnectionTransportFeature.Transport

src\Servers\Kestrel\shared\TransportMultiplexedConnection.cs (1)

34public IDuplexPipe Application { get; set; } = default!;

src\Shared\ServerInfrastructure\DuplexPipe.cs (7)

9/// An <see cref="IDuplexPipe"/> is *not* a pipe. It is also a reader-writer pair, but the reader and writer are not 14/// A <see cref="DuplexPipePair"/> is a pair of <see cref="IDuplexPipe"/> instances, each of which represents one end of 16/// <see cref="Pipe"/>s, as these underlie the <see cref="IDuplexPipe"/> instances. In either view, it is composed of 45public IDuplexPipe Transport { get; } 46public IDuplexPipe Application { get; } 48public DuplexPipePair(IDuplexPipe transport, IDuplexPipe application)

Internal\SocketConnection.cs (1)

22private readonly IDuplexPipe _originalTransport;

src\Servers\Kestrel\shared\TransportConnection.cs (2)

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

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

21IDuplexPipe IConnectionTransportFeature.Transport

src\Shared\ServerInfrastructure\DuplexPipe.cs (7)

9/// An <see cref="IDuplexPipe"/> is *not* a pipe. It is also a reader-writer pair, but the reader and writer are not 14/// A <see cref="DuplexPipePair"/> is a pair of <see cref="IDuplexPipe"/> instances, each of which represents one end of 16/// <see cref="Pipe"/>s, as these underlie the <see cref="IDuplexPipe"/> instances. In either view, it is composed of 45public IDuplexPipe Transport { get; } 46public IDuplexPipe Application { get; } 48public DuplexPipePair(IDuplexPipe transport, IDuplexPipe application)

src\Shared\ServerInfrastructure\DuplexPipe.cs (7)

9/// An <see cref="IDuplexPipe"/> is *not* a pipe. It is also a reader-writer pair, but the reader and writer are not 14/// A <see cref="DuplexPipePair"/> is a pair of <see cref="IDuplexPipe"/> instances, each of which represents one end of 16/// <see cref="Pipe"/>s, as these underlie the <see cref="IDuplexPipe"/> instances. In either view, it is composed of 45public IDuplexPipe Transport { get; } 46public IDuplexPipe Application { get; } 48public DuplexPipePair(IDuplexPipe transport, IDuplexPipe application)

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (3)

12/// A helper for wrapping a Stream decorator from an <see cref="IDuplexPipe"/>. 20public DuplexPipeStreamAdapter(IDuplexPipe duplexPipe, Func<Stream, TStream> createStream) : 25public DuplexPipeStreamAdapter(IDuplexPipe duplexPipe, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions, Func<Stream, TStream> createStream) :

src\Shared\ServerInfrastructure\SslDuplexPipe.cs (2)

14public SslDuplexPipe(IDuplexPipe transport, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions) 19public SslDuplexPipe(IDuplexPipe transport, StreamPipeReaderOptions readerOptions, StreamPipeWriterOptions writerOptions, Func<Stream, SslStream> factory) :

HubConnectionTests.Reconnect.cs (1)

1179public override IDuplexPipe Transport { get => _inner.Transport; set => _inner.Transport = value; }

TestConnection.cs (2)

38public IDuplexPipe Application { get; } 39public override IDuplexPipe Transport { get; set; }

TestTransport.cs (2)

20public IDuplexPipe Application { get; private set; } 23private IDuplexPipe _transport;

BroadcastBenchmark.cs (1)

74private static async Task ConsumeAsync(IDuplexPipe application)

Shared\TestConnectionContext.cs (1)

15public override IDuplexPipe Transport { get; set; }

src\SignalR\common\Shared\DuplexPipe.cs (4)

32public IDuplexPipe Transport { get; } 33public IDuplexPipe Application { get; } 35public DuplexPipePair(IDuplexPipe transport, IDuplexPipe application)

EndToEndTests.cs (2)

703private IDuplexPipe _application; 704private IDuplexPipe _transport;

HubConnectionHandlerTests.cs (6)

2990private readonly IDuplexPipe _originalDuplexPipe; 2993public CustomDuplex(IDuplexPipe duplexPipe) 5273public IDuplexPipe Transport { get; set; } 5274public IDuplexPipe Application { get; set; } 5276public DuplexPipePair(IDuplexPipe transport, IDuplexPipe application)

Internal\MessageBufferTests.cs (5)

503public override IDuplexPipe Transport { get; set; } 532public IDuplexPipe Transport { get; set; } 533public IDuplexPipe Application { get; set; } 535public DuplexPipePair(IDuplexPipe transport, IDuplexPipe application)

src\SignalR\common\Shared\DuplexPipe.cs (4)

32public IDuplexPipe Transport { get; } 33public IDuplexPipe Application { get; } 35public DuplexPipePair(IDuplexPipe transport, IDuplexPipe application)

BrokeredServices\MockServiceBroker.cs (1)

22public ValueTask<IDuplexPipe?> GetPipeAsync(ServiceMoniker serviceMoniker, ServiceActivationOptions options = default, CancellationToken cancellationToken = default)

BrokeredServices\WrappedServiceBroker.cs (1)

37public async ValueTask<IDuplexPipe?> GetPipeAsync(ServiceMoniker serviceMoniker, ServiceActivationOptions options = default, CancellationToken cancellationToken = default)

Services\BrokeredServiceBase.FactoryBase.cs (3)

28object Create(IDuplexPipe pipe, IServiceProvider hostProvidedServices, ServiceActivationOptions serviceActivationOptions, IServiceBroker serviceBroker); 84object IFactory.Create(IDuplexPipe pipe, IServiceProvider hostProvidedServices, ServiceActivationOptions serviceActivationOptions, IServiceBroker serviceBroker) 90IDuplexPipe pipe,

Remote\InProcRemostHostClient.cs (2)

118public ValueTask<IDuplexPipe?> GetPipeAsync(ServiceMoniker serviceMoniker, ServiceActivationOptions options, CancellationToken cancellationToken) 231public object CreateBrokeredService(ServiceRpcDescriptor descriptor, IDuplexPipe pipe, ServiceActivationOptions options)

Remote\ServiceDescriptorTests.cs (1)

135type != typeof(IDuplexPipe) &&

Diagnostics\ExternalDiagnosticUpdateSourceTests.vb (1)

363Public Function GetPipeAsync(serviceMoniker As ServiceMoniker, Optional options As ServiceActivationOptions = Nothing, Optional cancellationToken As CancellationToken = Nothing) As ValueTask(Of IDuplexPipe) Implements IServiceBroker.GetPipeAsync

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)

29public PassThroughDuplexPipe(IDuplexPipe duplexPipe)