35 implementations of Input
ClientSample (1)
src\SignalR\common\Shared\DuplexPipe.cs (1)
14public PipeReader Input { get; }
http2cat (1)
src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)
36public PipeReader Input { get; }
IIS.FunctionalTests (1)
src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)
36public PipeReader Input { get; }
IIS.LongTests (1)
src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)
36public PipeReader Input { get; }
IIS.NewHandler.FunctionalTests (1)
src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)
36public PipeReader Input { get; }
IIS.ShadowCopy.Tests (1)
src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)
36public PipeReader Input { get; }
IISExpress.FunctionalTests (1)
src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)
36public PipeReader Input { get; }
InMemory.FunctionalTests (2)
src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)
35public PipeReader Input { get; }
TestTransport\InMemoryTransportConnection.cs (1)
109public PipeReader Input { get; }
Microsoft.AspNetCore.Http.Connections (1)
src\SignalR\common\Shared\DuplexPipe.cs (1)
14public PipeReader Input { get; }
Microsoft.AspNetCore.Http.Connections.Client (4)
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; }
Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (1)
src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)
36public PipeReader Input { get; }
Microsoft.AspNetCore.Server.IIS (2)
src\Shared\ServerInfrastructure\DuplexPipe.cs (1)
27public PipeReader Input { get; }
src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)
36public PipeReader Input { get; }
Microsoft.AspNetCore.Server.Kestrel.Core (2)
src\Shared\ServerInfrastructure\DuplexPipe.cs (1)
27public PipeReader Input { get; }
src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)
36public PipeReader Input { get; }
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (1)
src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)
35public PipeReader Input { get; }
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (1)
Mocks\MockDuplexPipe.cs (1)
16public PipeReader Input { get; }
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (1)
src\Shared\ServerInfrastructure\DuplexPipe.cs (1)
27public PipeReader Input { get; }
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (1)
src\Shared\ServerInfrastructure\DuplexPipe.cs (1)
27public PipeReader Input { get; }
Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets (1)
src\Shared\ServerInfrastructure\DuplexPipe.cs (1)
27public PipeReader Input { get; }
Microsoft.AspNetCore.Shared.Tests (2)
src\Shared\ServerInfrastructure\DuplexPipe.cs (1)
27public PipeReader Input { get; }
src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)
36public PipeReader Input { get; }
Microsoft.AspNetCore.SignalR.Client.Tests (1)
TestTransport.cs (1)
25public PipeReader Input => _transport.Input;
Microsoft.AspNetCore.SignalR.Microbenchmarks (1)
Shared\TestDuplexPipe.cs (1)
12public PipeReader Input => _input;
Microsoft.AspNetCore.SignalR.Specification.Tests (1)
src\SignalR\common\Shared\DuplexPipe.cs (1)
14public PipeReader Input { get; }
Microsoft.AspNetCore.SignalR.Tests (3)
EndToEndTests.cs (1)
707public PipeReader Input => _transport.Input;
HubConnectionHandlerTests.cs (1)
2999public PipeReader Input => WrappedPipeReader;
Internal\MessageBufferTests.cs (1)
571public PipeReader Input { get; }
Microsoft.AspNetCore.SignalR.Tests.Utils (1)
src\SignalR\common\Shared\DuplexPipe.cs (1)
14public PipeReader Input { get; }
Sockets.FunctionalTests (2)
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);
410 references to Input
ClientSample (5)
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);
http2cat (3)
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)
IIS.FunctionalTests (3)
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)
IIS.LongTests (3)
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)
IIS.NewHandler.FunctionalTests (3)
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)
IIS.ShadowCopy.Tests (1)
src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)
26base(duplexPipe.Input, duplexPipe.Output)
IISExpress.FunctionalTests (3)
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)
InMemory.FunctionalTests (31)
Http2\Http2ConnectionTests.cs (10)
4324_pair.Transport.Input.Complete(); 4403_pair.Transport.Input.Complete(); 5140var result = await _pair.Application.Input.ReadAsync().AsTask().DefaultTimeout(); 5202var readTask = _pair.Application.Input.ReadAsync(); 5203_pair.Application.Input.CancelPendingRead(); 5212readTask = _pair.Application.Input.ReadAsync(); 5213_pair.Application.Input.CancelPendingRead(); 5317var result = await _pair.Application.Input.ReadAsync().AsTask().DefaultTimeout(); 5531_pair.Transport.Input.Complete(); 5613_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)
555return Pair.Application.Input.ReadAsync().AsTask().DefaultTimeout(); 616Pair.Application.Input.AdvanceTo(consumed, examined); 968Pair.Application.Input.AdvanceTo(consumed, examined); 1147_pair.Application.Input.Complete(); 1249_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();
Microsoft.AspNetCore.Http.Connections (13)
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();
Microsoft.AspNetCore.Http.Connections.Client (20)
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);
Microsoft.AspNetCore.Http.Connections.Tests (50)
HttpConnectionDispatcherTests.cs (25)
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(); 543var result = await connectionContext.Transport.Input.ReadAsync(); 612Assert.True(connection.Transport.Input.TryRead(out var result)); 615connection.Transport.Input.AdvanceTo(result.Buffer.End); 3555await connection.Transport.Input.ReadAsync(); 3821var result = connection.Transport.Input.ReadAsync().AsTask().Result; 3822connection.Transport.Input.AdvanceTo(result.Buffer.End); 3849var result = await connection.Transport.Input.ReadAsync(); 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(); 3927connection.Transport.Input.AdvanceTo(result.Buffer.End); 3939var result = await connection.Transport.Input.ReadAsync(); 3956connection.Transport.Input.AdvanceTo(result.Buffer.End); 3969var result = await connection.Transport.Input.ReadAsync(); 3983connection.Transport.Input.AdvanceTo(result.Buffer.End); 3996var result = await connection.Transport.Input.ReadAsync(); 4010connection.Transport.Input.AdvanceTo(result.Buffer.End); 4045var res = await connection.Transport.Input.ReadAsync(connection.ConnectionClosed); 4058connection.Transport.Input.AdvanceTo(res.Buffer.End);
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);
Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (3)
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)
Microsoft.AspNetCore.Server.IIS (1)
src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)
26base(duplexPipe.Input, duplexPipe.Output)
Microsoft.AspNetCore.Server.Kestrel.Core (11)
Internal\Http\Http1Connection.cs (1)
90Input = _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)
81public 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)
86public 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)
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (47)
Http1\Http1ConnectionTests.cs (39)
35var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 38_transport.Input.AdvanceTo(_consumed, _examined); 54var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 70var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 81var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 84_transport.Input.AdvanceTo(_consumed, _examined); 98var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 101_transport.Input.AdvanceTo(_consumed, _examined); 124var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 134_transport.Input.AdvanceTo(TakeStartLineAndMessageHeaders()); 139readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 148_transport.Input.AdvanceTo(TakeMessageHeaders()); 202var read = await _application.Input.ReadAsync(); 214_application.Input.AdvanceTo(consumed, examined); 277var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 280_transport.Input.AdvanceTo(_consumed, _examined); 289readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 292_transport.Input.AdvanceTo(_consumed, _examined); 414var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 417_transport.Input.AdvanceTo(_consumed, _examined); 437var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 440_transport.Input.AdvanceTo(_consumed, _examined); 456var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 458_transport.Input.AdvanceTo(_consumed, _examined); 469var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 473_transport.Input.AdvanceTo(_consumed, _examined); 483var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 487_transport.Input.AdvanceTo(_consumed, _examined); 500var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 504_transport.Input.AdvanceTo(_consumed, _examined); 517var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 521_transport.Input.AdvanceTo(_consumed, _examined); 534var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 538_transport.Input.AdvanceTo(_consumed, _examined); 549var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 555_transport.Input.AdvanceTo(_consumed, _examined); 820_application.Input.Complete(); 838var readableBuffer = (await _transport.Input.ReadAsync()).Buffer; 842_transport.Input.AdvanceTo(_consumed, _examined);
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();
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (14)
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)
560return Pair.Application.Input.ReadAsync(); 616Pair.Application.Input.AdvanceTo(consumed, examined); 968Pair.Application.Input.AdvanceTo(consumed, examined); 1147_pair.Application.Input.Complete(); 1249_pair.Transport.Input.Complete();
src\Servers\Kestrel\shared\TransportConnection.cs (1)
73Application.Input.CancelPendingRead();
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (3)
Internal\NamedPipeConnection.cs (2)
59public PipeReader Output => Application.Input; 282_originalTransport.Input.Complete();
src\Servers\Kestrel\shared\TransportConnection.cs (1)
73Application.Input.CancelPendingRead();
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (4)
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();
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic.Tests (65)
QuicConnectionContextTests.cs (36)
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(); 217var read = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).DefaultTimeout(); 219serverStream.Transport.Input.AdvanceTo(read.Buffer.End); 230read = await serverStream.Transport.Input.ReadAsync().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(); 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(); 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(); 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(); 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(); 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();
QuicStreamContextTests.cs (25)
70var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).DefaultTimeout(); 71serverStream.Transport.Input.AdvanceTo(readResult.Buffer.End); 82await serverStream.Transport.Input.CompleteAsync(); 123var readResult = await serverStream.Transport.Input.ReadAtLeastAsync(TestData.Length).DefaultTimeout(); 124serverStream.Transport.Input.AdvanceTo(readResult.Buffer.End); 132await serverStream.Transport.Input.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(); 203await serverStream.Transport.Input.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(); 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(); 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();
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();
Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets (3)
Internal\SocketConnection.cs (2)
74public PipeReader Output => Application.Input; 104_originalTransport.Input.Complete();
src\Servers\Kestrel\shared\TransportConnection.cs (1)
73Application.Input.CancelPendingRead();
Microsoft.AspNetCore.Shared.Tests (1)
src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)
26base(duplexPipe.Input, duplexPipe.Output)
Microsoft.AspNetCore.SignalR.Client.Core (4)
HubConnection.cs (4)
1509var input = startingConnectionState.Connection.Transport.Input; 1634var input = connectionState.Connection.Transport.Input; 2267Connection.Transport.Input.CancelPendingRead(); 2392Connection.Transport.Input.CancelPendingRead();
Microsoft.AspNetCore.SignalR.Client.Tests (17)
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();
Microsoft.AspNetCore.SignalR.Core (1)
HubConnectionContext.cs (1)
159internal PipeReader Input => _connectionContext.Transport.Input;
Microsoft.AspNetCore.SignalR.Microbenchmarks (3)
BroadcastBenchmark.cs (3)
78var result = await application.Input.ReadAsync(); 83application.Input.AdvanceTo(buffer.End); 91application.Input.Complete();
Microsoft.AspNetCore.SignalR.Specification.Tests (4)
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);
Microsoft.AspNetCore.SignalR.Tests (78)
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)
35var res = await pipes.Application.Input.ReadAsync().DefaultTimeout(); 41pipes.Application.Input.AdvanceTo(buffer.Start); 60var res = await pipes.Application.Input.ReadAsync(); 66pipes.Application.Input.AdvanceTo(buffer.Start); 74res = await pipes.Application.Input.ReadAsync().DefaultTimeout(); 80pipes.Application.Input.AdvanceTo(buffer.Start); 102var res = await pipes.Application.Input.ReadAsync(); 107pipes.Application.Input.AdvanceTo(buffer.Start); 111res = await pipes.Application.Input.ReadAsync(); 116pipes.Application.Input.AdvanceTo(buffer.Start); 119Assert.False(pipes.Application.Input.TryRead(out res)); 135var res = await pipes.Application.Input.ReadAsync(); 141pipes.Application.Input.AdvanceTo(buffer.Start); 150res = await pipes.Application.Input.ReadAsync(); 157pipes.Application.Input.AdvanceTo(buffer.Start); 159res = await pipes.Application.Input.ReadAsync(); 165pipes.Application.Input.AdvanceTo(buffer.Start); 187var res = await pipes.Application.Input.ReadAsync(); 195pipes.Application.Input.AdvanceTo(buffer.Start); 204res = await pipes.Application.Input.ReadAsync(); 211pipes.Application.Input.AdvanceTo(buffer.Start); 213res = await pipes.Application.Input.ReadAsync(); 221pipes.Application.Input.AdvanceTo(buffer.Start); 240var res = await pipes.Application.Input.ReadAsync(); 246pipes.Application.Input.AdvanceTo(buffer.Start); 253res = await pipes.Application.Input.ReadAsync(); 260pipes.Application.Input.AdvanceTo(buffer.Start); 264res = await pipes.Application.Input.ReadAsync(); 270pipes.Application.Input.AdvanceTo(buffer.Start); 285var res = await pipes.Application.Input.ReadAsync(); 292pipes.Application.Input.AdvanceTo(buffer.Start); 317var res = await pipes.Application.Input.ReadAsync(); 324pipes.Application.Input.AdvanceTo(buffer.Start); 328res = await pipes.Application.Input.ReadAsync(); 334pipes.Application.Input.AdvanceTo(buffer.Start); 337Assert.False(pipes.Application.Input.TryRead(out res)); 354var res = await pipes.Application.Input.ReadAsync(); 360pipes.Application.Input.AdvanceTo(buffer.Start); 368res = await pipes.Application.Input.ReadAsync().DefaultTimeout(); 374pipes.Application.Input.AdvanceTo(buffer.Start); 389pipes.Application.Input.Complete(); 399var res = await pipes.Application.Input.ReadAsync(); 404pipes.Application.Input.AdvanceTo(buffer.Start); 408res = await pipes.Application.Input.ReadAsync(); 413pipes.Application.Input.AdvanceTo(buffer.Start); 416Assert.False(pipes.Application.Input.TryRead(out res)); 435var res = await pipes.Application.Input.ReadAsync(); 439pipes.Application.Input.AdvanceTo(buffer.Start); 447res = await pipes.Application.Input.ReadAsync(); 451pipes.Application.Input.AdvanceTo(buffer.Start); 479var res = await pipes.Application.Input.ReadAsync(); 483pipes.Application.Input.AdvanceTo(buffer.Start); 487res = await pipes.Application.Input.ReadAsync(); 491pipes.Application.Input.AdvanceTo(buffer.Start); 526var res = await pipes.Application.Input.ReadAsync(); 530pipes.Application.Input.AdvanceTo(buffer.Start); 536res = await pipes.Application.Input.ReadAsync(); 540pipes.Application.Input.AdvanceTo(buffer.Start); 545res = await pipes.Application.Input.ReadAsync(); 549pipes.Application.Input.AdvanceTo(buffer.Start); 551Assert.False(pipes.Application.Input.TryRead(out res)); 604var transportToApplication = new DuplexPipe(duplexPipePair.Transport.Input, input.Writer);
WriteThenCloseConnectionHandler.cs (2)
14var result = await connection.Transport.Input.ReadAsync(); 22connection.Transport.Input.AdvanceTo(buffer.End);
Microsoft.AspNetCore.SignalR.Tests.Utils (4)
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);
SignalR.Client.FunctionalTestApp (2)
EchoConnectionHandler.cs (2)
15var result = await connection.Transport.Input.ReadAsync(); 31connection.Transport.Input.AdvanceTo(result.Buffer.End);
SignalRSamples (2)
ConnectionHandlers\MessagesConnectionHandler.cs (2)
27var result = await connection.Transport.Input.ReadAsync(); 46connection.Transport.Input.AdvanceTo(buffer.End);
SocialWeather (2)
SocialWeatherConnectionHandler.cs (2)
37var result = await connection.Transport.Input.ReadAsync(); 57connection.Transport.Input.AdvanceTo(buffer.End);
Sockets.FunctionalTests (3)
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);
WebTransportInteractiveSampleApp (2)
Program.cs (2)
95var inputPipe = stream.Transport.Input; 115var inputPipe = stream.Transport.Input;
WebTransportSampleApp (1)
Program.cs (1)
38var test = await stream.Transport.Input.AsStream().ReadAsync(memory, CancellationToken.None);