Input

4 implementations of Input

Microsoft.AspNetCore.Http.Connections (1)

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

14public 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; }

29 references to Input

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)

155var 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.Server.Kestrel.Core (11)

Internal\Http\Http1Connection.cs (1)

91Input = _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; 553_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.Core (1)

HubConnectionContext.cs (1)

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