Input

11 implementations of Input

Microsoft.AspNetCore.Http.Connections (1)

src\aspnetcore\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\aspnetcore\src\SignalR\common\Shared\DuplexPipe.cs (1)

14public PipeReader Input { get; }

Microsoft.AspNetCore.Server.IIS (2)

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

27public PipeReader Input { get; }

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

36public PipeReader Input { get; }

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

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

27public PipeReader Input { get; }

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

36public PipeReader Input { get; }

Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (1)

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

27public PipeReader Input { get; }

Microsoft.AspNetCore.SignalR.Specification.Tests (1)

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

14public PipeReader Input { get; }

58 references to Input

Microsoft.AspNetCore.Http.Connections (13)

Internal\HttpConnectionContext.cs (8)

458Application?.Input.CancelPendingRead(); 469Transport?.Input.Complete(); 484Application?.Input.Complete(); 494Application?.Input.Complete(); 511Transport?.Input.Complete(); 617var longPolling = new LongPollingServerTransport(timeoutSource.Token, Application.Input, loggerFactory, this); 685Application.Input.CancelPendingRead(); 839var transportToApplication = new DuplexPipe(Transport.Input, input.Writer);

Internal\HttpConnectionDispatcher.cs (1)

378var 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.Server.IIS (1)

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

26base(duplexPipe.Input, duplexPipe.Output)

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

Internal\Http\Http1Connection.cs (1)

94Input = _context.Transport.Input;

Internal\Http2\Http2Connection.cs (2)

197_inputTask = CopyPipeAsync(_context.Transport.Input, _input.Writer); 497_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)

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

Internal\WebTransport\WebTransportStream.cs (1)

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

Middleware\TlsListener.cs (1)

27var input = connection.Transport.Input;

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

26base(duplexPipe.Input, duplexPipe.Output)

Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (4)

Internal\QuicStreamContext.cs (2)

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

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

73Application.Input.CancelPendingRead();

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

59Application.Input.CancelPendingRead();

Microsoft.AspNetCore.SignalR.Client.Core (4)

HubConnection.cs (4)

1683var input = startingConnectionState.Connection.Transport.Input; 1808var input = connectionState.Connection.Transport.Input; 2441Connection.Transport.Input.CancelPendingRead(); 2580Connection.Transport.Input.CancelPendingRead();

Microsoft.AspNetCore.SignalR.Core (1)

HubConnectionContext.cs (1)

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

Microsoft.AspNetCore.SignalR.Specification.Tests (4)

src\aspnetcore\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);