Input

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

14public PipeReader Input { get; }

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

36public PipeReader Input { get; }

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

36public PipeReader Input { get; }

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

36public PipeReader Input { get; }

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

36public PipeReader Input { get; }

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

36public PipeReader Input { get; }

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

36public PipeReader Input { get; }

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

36public PipeReader Input { get; }

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

35public PipeReader Input { get; }

TestTransport\InMemoryTransportConnection.cs (1)

109public PipeReader Input { get; }

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

14public PipeReader Input { get; }

Internal\LongPollingTransport.cs (1)

32public PipeReader Input => _transport!.Input;

Internal\ServerSentEventsTransport.cs (1)

33public PipeReader Input => _transport!.Input;

Internal\WebSocketsTransport.cs (1)

51public PipeReader Input => _transport!.Input;

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

14public PipeReader Input { get; }

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

36public PipeReader Input { get; }

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

27public PipeReader Input { get; }

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

36public PipeReader Input { get; }

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

27public PipeReader Input { get; }

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

36public PipeReader Input { get; }

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

35public PipeReader Input { get; }

Mocks\MockDuplexPipe.cs (1)

16public PipeReader Input { get; }

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

27public PipeReader Input { get; }

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

27public PipeReader Input { get; }

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

27public PipeReader Input { get; }

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

27public PipeReader Input { get; }

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

36public PipeReader Input { get; }

TestTransport.cs (1)

25public PipeReader Input => _transport.Input;

Shared\TestDuplexPipe.cs (1)

12public PipeReader Input => _input;

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

14public PipeReader Input { get; }

EndToEndTests.cs (1)

707public PipeReader Input => _transport.Input;

HubConnectionHandlerTests.cs (1)

2999public PipeReader Input => WrappedPipeReader;

Internal\MessageBufferTests.cs (1)

571public PipeReader Input { get; }

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

14public PipeReader Input { get; }

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

35public PipeReader Input { get; }

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

84public PipeReader Input => new MockPipeReader(this);

RawSample.cs (1)

57_ = ReceiveLoop(Console.Out, connection.Transport.Input);

Tcp\TcpConnection.cs (4)

52Transport?.Input.Complete(); 105_application.Input.Complete(sendError); 221var result = await _application.Input.ReadAsync(); 236_application.Input.AdvanceTo(end);

src\Shared\Http2cat\Http2Utilities.cs (2)

839var result = await _pair.Application.Input.ReadAsync().AsTask().DefaultTimeout(); 867_pair.Application.Input.AdvanceTo(consumed, examined);

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

26base(duplexPipe.Input, duplexPipe.Output)

src\Shared\Http2cat\Http2Utilities.cs (2)

839var result = await _pair.Application.Input.ReadAsync().AsTask().DefaultTimeout(); 867_pair.Application.Input.AdvanceTo(consumed, examined);

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

26base(duplexPipe.Input, duplexPipe.Output)

src\Shared\Http2cat\Http2Utilities.cs (2)

839var result = await _pair.Application.Input.ReadAsync().AsTask().DefaultTimeout(); 867_pair.Application.Input.AdvanceTo(consumed, examined);

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

26base(duplexPipe.Input, duplexPipe.Output)

src\Shared\Http2cat\Http2Utilities.cs (2)

839var result = await _pair.Application.Input.ReadAsync().AsTask().DefaultTimeout(); 867_pair.Application.Input.AdvanceTo(consumed, examined);

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

26base(duplexPipe.Input, duplexPipe.Output)

src\Shared\Http2cat\Http2Utilities.cs (2)

839var result = await _pair.Application.Input.ReadAsync().AsTask().DefaultTimeout(); 867_pair.Application.Input.AdvanceTo(consumed, examined);

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

26base(duplexPipe.Input, duplexPipe.Output)

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

26base(duplexPipe.Input, duplexPipe.Output)

src\Shared\Http2cat\Http2Utilities.cs (2)

839var result = await _pair.Application.Input.ReadAsync().AsTask().DefaultTimeout(); 867_pair.Application.Input.AdvanceTo(consumed, examined);

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

26base(duplexPipe.Input, duplexPipe.Output)

Http2\Http2ConnectionTests.cs (10)

4313_pair.Transport.Input.Complete(); 4392_pair.Transport.Input.Complete(); 5129var result = await _pair.Application.Input.ReadAsync().AsTask().DefaultTimeout(); 5191var readTask = _pair.Application.Input.ReadAsync(); 5192_pair.Application.Input.CancelPendingRead(); 5201readTask = _pair.Application.Input.ReadAsync(); 5202_pair.Application.Input.CancelPendingRead(); 5306var result = await _pair.Application.Input.ReadAsync().AsTask().DefaultTimeout(); 5520_pair.Transport.Input.Complete(); 5602_pair.Transport.Input.Complete();

Http2\Http2TestBase.cs (7)

419_pair.Application?.Input.Complete(); 421_pair.Transport?.Input.Complete(); 565_pair.Transport.Input.Complete(); 1214var result = await _pair.Application.Input.ReadAsync().AsTask().DefaultTimeout(); 1222_pair.Application.Input.AdvanceTo(result.Buffer.Start, result.Buffer.End); 1232var result = await _pair.Application.Input.ReadAsync().AsTask().DefaultTimeout(); 1261_pair.Application.Input.AdvanceTo(consumed, examined);

Http2\Http2TimeoutTests.cs (2)

390Assert.True((await _pair.Application.Input.ReadAsync().AsTask().DefaultTimeout()).IsCompleted); 445Assert.True((await _pair.Application.Input.ReadAsync().AsTask().DefaultTimeout()).IsCompleted);

Http3\WebTransport\WebTransportStreamTests.cs (1)

47var length = await stream.Transport.Input.AsStream().ReadAsync(memoryOut, CancellationToken.None);

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

537return Pair.Application.Input.ReadAsync().AsTask().DefaultTimeout(); 598Pair.Application.Input.AdvanceTo(consumed, examined); 950Pair.Application.Input.AdvanceTo(consumed, examined); 1129_pair.Application.Input.Complete(); 1231_pair.Transport.Input.Complete();

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

31Input = new PassThroughPipeReader(duplexPipe.Input);

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

73Application.Input.CancelPendingRead();

TestTransport\InMemoryTransportConnection.cs (3)

43public PipeReader Output => Application.Input; 83Transport.Input.Complete(); 100_reader = new ObservablePipeReader(duplexPipe.Input);

UpgradeTests.cs (1)

405connectionTransportFeature.Transport.Input.CancelPendingRead();

Internal\HttpConnectionContext.cs (8)

331Application?.Input.CancelPendingRead(); 342Transport?.Input.Complete(); 357Application?.Input.Complete(); 367Application?.Input.Complete(); 384Transport?.Input.Complete(); 490var longPolling = new LongPollingServerTransport(timeoutSource.Token, Application.Input, loggerFactory, this); 558Application.Input.CancelPendingRead(); 712var transportToApplication = new DuplexPipe(Transport.Input, input.Writer);

Internal\HttpConnectionDispatcher.cs (1)

154var sse = new ServerSentEventsServerTransport(connection.Application.Input, connection.ConnectionId, connection, _loggerFactory);

Internal\Transports\WebSocketsServerTransport.cs (4)

79_application.Input.CancelPendingRead(); 208var result = await _application.Input.ReadAsync(); 265_application.Input.AdvanceTo(buffer.End); 291_application.Input.Complete();

Internal\LongPollingTransport.cs (4)

32public PipeReader Input => _transport!.Input; 91_application.Input.CancelPendingRead(); 123_application.Input.CancelPendingRead(); 136_transport!.Input.Complete();

Internal\SendUtils.cs (3)

27var result = await application.Input.ReadAsync(cancellationToken).ConfigureAwait(false); 69application.Input.AdvanceTo(buffer.End); 84application.Input.Complete();

Internal\ServerSentEventsTransport.cs (4)

33public PipeReader Input => _transport!.Input; 108_application.Input.CancelPendingRead(); 185_transport!.Input.Complete(); 187_application.Input.CancelPendingRead();

Internal\WebSocketsTransport.cs (9)

51public PipeReader Input => _transport!.Input; 365_application.Input.CancelPendingRead(); 428_application.Input.Complete(); 540var result = await _application.Input.ReadAsync().ConfigureAwait(false); 585_application.Input.AdvanceTo(buffer.End); 619_application.Input.Complete(); 667_transport!.Input.Complete(); 670_application.Input.CancelPendingRead(); 710var transportToApplication = new DuplexPipe(_transport!.Input, input.Writer);

HttpConnectionDispatcherTests.cs (25)

HttpConnectionManagerTests.cs (10)

90var result = await connection.Application.Input.ReadAsync(); 91connection.Application.Input.AdvanceTo(result.Buffer.End); 109var result = await connection.Transport.Input.ReadAsync(); 110connection.Transport.Input.AdvanceTo(result.Buffer.End); 134var exception = await Assert.ThrowsAsync<InvalidOperationException>(async () => await connection.Transport.Input.ReadAsync()); 137exception = await Assert.ThrowsAsync<InvalidOperationException>(async () => await connection.Application.Input.ReadAsync()); 251var result = await connection.Transport.Input.ReadAsync(); 259connection.Transport.Input.AdvanceTo(result.Buffer.End); 265var result = await connection.Application.Input.ReadAsync(); 272connection.Application.Input.AdvanceTo(result.Buffer.End);

LongPollingTests.cs (4)

30var poll = new LongPollingServerTransport(CancellationToken.None, connection.Application.Input, LoggerFactory); 50var poll = new LongPollingServerTransport(timeoutToken, connection.Application.Input, LoggerFactory); 71var poll = new LongPollingServerTransport(CancellationToken.None, connection.Application.Input, LoggerFactory); 94var poll = new LongPollingServerTransport(CancellationToken.None, connection.Application.Input, LoggerFactory);

MapConnectionHandlerTests.cs (2)

436var result = await connection.Transport.Input.ReadAsync(); 444connection.Transport.Input.AdvanceTo(result.Buffer.Start);

ServerSentEventsTests.cs (5)

28var sse = new ServerSentEventsServerTransport(connection.Application.Input, connectionId: string.Empty, LoggerFactory); 51var sse = new ServerSentEventsServerTransport(connection.Application.Input, connectionId: connection.ConnectionId, LoggerFactory); 72var sse = new ServerSentEventsServerTransport(connection.Application.Input, connectionId: string.Empty, LoggerFactory); 94var sse = new ServerSentEventsServerTransport(connection.Application.Input, connectionId: string.Empty, LoggerFactory); 120var sse = new ServerSentEventsServerTransport(connection.Application.Input, connectionId: string.Empty, LoggerFactory);

WebSocketsTests.cs (4)

54var result = await connection.Transport.Input.ReadAsync(); 57connection.Transport.Input.AdvanceTo(buffer.End); 132var result = await connection.Transport.Input.ReadAsync(); 133connection.Transport.Input.AdvanceTo(result.Buffer.End);

src\Shared\Http2cat\Http2Utilities.cs (2)

839var result = await _pair.Application.Input.ReadAsync().AsTask().DefaultTimeout(); 867_pair.Application.Input.AdvanceTo(consumed, examined);

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

26base(duplexPipe.Input, duplexPipe.Output)

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

26base(duplexPipe.Input, duplexPipe.Output)

Internal\Http\Http1Connection.cs (1)

67Input = _context.Transport.Input;

Internal\Http2\Http2Connection.cs (2)

193_inputTask = CopyPipeAsync(_context.Transport.Input, _input.Writer); 493_context.Transport.Input.CancelPendingRead();

Internal\Http3\Http3ControlStream.cs (1)

75public PipeReader Input => _context.Transport.Input;

Internal\Http3\Http3PendingStream.cs (3)

35Context.Transport.Input.CancelPendingRead(); 36Context.Transport.Input.Complete(exception); 42var Input = context.Transport.Input;

Internal\Http3\Http3Stream.cs (1)

72public PipeReader Input => _context.Transport.Input;

Internal\WebTransport\WebTransportStream.cs (1)

60_duplexPipe = new DuplexPipe(context.Transport.Input, context.Transport.Output);

Middleware\TlsListener.cs (1)

24var input = connection.Transport.Input;

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

26base(duplexPipe.Input, duplexPipe.Output)

Http1\Http1ConnectionTests.cs (41)

Http1\Http1ConnectionTestsBase.cs (2)

70_transport.Input.Complete(); 73_application.Input.Complete();

MessageBodyTests.cs (1)

716input.Transport.Input.CancelPendingRead();

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

31Input = new PassThroughPipeReader(duplexPipe.Input);

StartLineTests.cs (1)

545Transport.Input.Complete();

TestHelpers\TestInput.cs (3)

79Transport.Input.CancelPendingRead(); 84Application.Input.Complete(); 86Transport.Input.Complete();

Http1LargeWritingBenchmark.cs (1)

95var reader = _pair.Application.Input;

Http1ReadingBenchmark.cs (1)

125var reader = _pair.Application.Input;

Http1WritingBenchmark.cs (1)

129var reader = _pair.Application.Input;

Http2\Http2ConnectionBenchmarkBase.cs (4)

105ReceiveFrameAsync(_connectionPair.Application.Input).GetAwaiter().GetResult(); 107ReceiveFrameAsync(_connectionPair.Application.Input).GetAwaiter().GetResult(); 109ReceiveFrameAsync(_connectionPair.Application.Input).GetAwaiter().GetResult(); 123await ReceiveFrameAsync(_connectionPair.Application.Input);

InMemoryTransportBenchmark.cs (1)

184public PipeReader Output => Application.Input;

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

542return Pair.Application.Input.ReadAsync(); 598Pair.Application.Input.AdvanceTo(consumed, examined); 950Pair.Application.Input.AdvanceTo(consumed, examined); 1129_pair.Application.Input.Complete(); 1231_pair.Transport.Input.Complete();

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

73Application.Input.CancelPendingRead();

Internal\NamedPipeConnection.cs (2)

59public PipeReader Output => Application.Input; 282_originalTransport.Input.Complete();

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

73Application.Input.CancelPendingRead();

Internal\QuicStreamContext.cs (2)

75private PipeReader Output => Application.Input; 553_originalTransport.Input.Complete();

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

73Application.Input.CancelPendingRead();

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

59Application.Input.CancelPendingRead();

QuicConnectionContextTests.cs (36)

QuicStreamContextTests.cs (25)

QuicTestHelpers.cs (4)

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();

Internal\SocketConnection.cs (2)

74public PipeReader Output => Application.Input; 104_originalTransport.Input.Complete();

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

73Application.Input.CancelPendingRead();

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

26base(duplexPipe.Input, duplexPipe.Output)

HubConnection.cs (4)

1509var input = startingConnectionState.Connection.Transport.Input; 1634var input = connectionState.Connection.Transport.Input; 2267Connection.Transport.Input.CancelPendingRead(); 2392Connection.Transport.Input.CancelPendingRead();

HttpConnectionTests.ConnectionLifecycle.cs (1)

317await Assert.ThrowsAsync<HttpRequestException>(async () => await connection.Transport.Input.ReadAsync());

HttpConnectionTests.Transport.cs (5)

218Assert.Contains("This is a test", Encoding.UTF8.GetString(await connection.Transport.Input.ReadAllAsync())); 409var message = await connection.Transport.Input.ReadAtLeastAsync(14); 447await Assert.ThrowsAsync<HttpRequestException>(async () => await connection.Transport.Input.ReadAllAsync()); 510await connection.Transport.Input.ReadAllAsync(); 551await Assert.ThrowsAsync<HttpRequestException>(async () => await connection.Transport.Input.ReadAllAsync());

HubConnectionTests.ConnectionLifecycle.cs (2)

174testConnection.Transport.Input.Complete(); 403await testConnection.Transport.Input.CompleteAsync();

TestConnection.cs (3)

148var result = await Application.Input.ReadAsync(); 167Application.Input.AdvanceTo(consumed); 211Transport.Input.Complete();

TestTransport.cs (6)

25public PipeReader Input => _transport.Input; 59var result = await Application.Input.ReadAsync(); 73Application.Input.AdvanceTo(result.Buffer.End); 81Application.Input.Complete(); 88_transport.Input.Complete(); 90Application.Input.CancelPendingRead();

HubConnectionContext.cs (1)

159internal PipeReader Input => _connectionContext.Transport.Input;

BroadcastBenchmark.cs (3)

78var result = await application.Input.ReadAsync(); 83application.Input.AdvanceTo(buffer.End); 91application.Input.Complete();

src\SignalR\common\testassets\Tests.Utils\TestClient.cs (4)

248var result = await Connection.Application.Input.ReadAsync(); 265Connection.Application.Input.AdvanceTo(buffer.Start); 277if (!Connection.Application.Input.TryRead(out var result)) 304Connection.Application.Input.AdvanceTo(buffer.Start);

AuthConnectionHandler.cs (2)

18var result = await connection.Transport.Input.ReadAsync(); 30connection.Transport.Input.AdvanceTo(buffer.End);

EchoConnectionHandler.cs (2)

16var result = await connection.Transport.Input.ReadAsync(); 28connection.Transport.Input.AdvanceTo(buffer.End);

EndToEndTests.cs (5)

195var receivedData = await connection.Transport.Input.ReadAsync(1); 293Assert.Equal(message, Encoding.UTF8.GetString(await connection.Transport.Input.ReadAsync(bytes.Length).DefaultTimeout())); 344var receivedData = await connection.Transport.Input.ReadAsync(bytes.Length).DefaultTimeout(); 707public PipeReader Input => _transport.Input; 751_application.Input.Complete();

HttpHeaderConnectionHandler.cs (2)

18var result = await connection.Transport.Input.ReadAsync(); 34connection.Transport.Input.AdvanceTo(buffer.End);

HubConnectionHandlerTests.cs (3)

2996WrappedPipeReader = new PipeReaderWrapper(_originalDuplexPipe.Input); 5303var prevPipe = connection.Application.Input; 5307var transportToApplication = new DuplexPipe(connection.Transport.Input, input.Writer);

Internal\MessageBufferTests.cs (62)

WriteThenCloseConnectionHandler.cs (2)

14var result = await connection.Transport.Input.ReadAsync(); 22connection.Transport.Input.AdvanceTo(buffer.End);

TestClient.cs (4)

248var result = await Connection.Application.Input.ReadAsync(); 265Connection.Application.Input.AdvanceTo(buffer.Start); 277if (!Connection.Application.Input.TryRead(out var result)) 304Connection.Application.Input.AdvanceTo(buffer.Start);

EchoConnectionHandler.cs (2)

15var result = await connection.Transport.Input.ReadAsync(); 31connection.Transport.Input.AdvanceTo(result.Buffer.End);

ConnectionHandlers\MessagesConnectionHandler.cs (2)

27var result = await connection.Transport.Input.ReadAsync(); 46connection.Transport.Input.AdvanceTo(buffer.End);

SocialWeatherConnectionHandler.cs (2)

37var result = await connection.Transport.Input.ReadAsync(); 57connection.Transport.Input.AdvanceTo(buffer.End);

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

31Input = new PassThroughPipeReader(duplexPipe.Input);

src\Servers\Kestrel\test\FunctionalTests\UnixDomainSocketsTests.cs (2)

55var result = await connection.Transport.Input.ReadAsync(notificationFeature.ConnectionClosedRequested); 65connection.Transport.Input.AdvanceTo(result.Buffer.End);

Program.cs (2)

95var inputPipe = stream.Transport.Input; 115var inputPipe = stream.Transport.Input;

Program.cs (1)

38var test = await stream.Transport.Input.AsStream().ReadAsync(memory, CancellationToken.None);