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;