5 overrides of Complete
Microsoft.AspNetCore.Server.Kestrel.Core (1)
Internal\Http\HttpRequestPipeReader.cs (1)
45public override void Complete(Exception? exception = null)
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (1)
src\aspnetcore\src\Servers\Kestrel\shared\CompletionPipeReader.cs (1)
40public override void Complete(Exception? exception = null)
System.IO.Pipelines (3)
System\IO\Pipelines\Pipe.DefaultPipeReader.cs (1)
34public override void Complete(Exception? exception = null) => _pipe.CompleteReader(exception);
System\IO\Pipelines\SequencePipeReader.cs (1)
50public override void Complete(Exception? exception = null)
System\IO\Pipelines\StreamPipeReader.cs (1)
168public override void Complete(Exception? exception = null)
41 references to Complete
Aspire.Cli.Tests (2)
Mcp\TestMcpServerTransport.cs (2)
71ClientToServerPipe.Reader.Complete(); 73ServerToClientPipe.Reader.Complete();
Aspire.Hosting (1)
Dcp\DcpHost.cs (1)
420reader.Complete();
Microsoft.AspNetCore.Http (1)
Features\RequestBodyPipeFeature.cs (1)
43((PipeReader)self).Complete();
Microsoft.AspNetCore.Http.Connections (5)
Internal\HttpConnectionContext.cs (4)
469Transport?.Input.Complete(); 484Application?.Input.Complete(); 494Application?.Input.Complete(); 511Transport?.Input.Complete();
Internal\Transports\WebSocketsServerTransport.cs (1)
291_application.Input.Complete();
Microsoft.AspNetCore.Http.Connections.Client (6)
Internal\LongPollingTransport.cs (1)
136_transport!.Input.Complete();
Internal\SendUtils.cs (1)
84application.Input.Complete();
Internal\ServerSentEventsTransport.cs (1)
185_transport!.Input.Complete();
Internal\WebSocketsTransport.cs (3)
428_application.Input.Complete(); 619_application.Input.Complete(); 667_transport!.Input.Complete();
Microsoft.AspNetCore.Server.IIS (2)
Core\IISHttpContext.IO.cs (1)
222_bodyOutput.Reader.Complete(error);
Core\IISHttpContextOfT.cs (1)
111_bodyInputPipe?.Reader.Complete();
Microsoft.AspNetCore.Server.Kestrel.Core (13)
Internal\Http\Http1ChunkedEncodingMessageBody.cs (1)
173_requestBodyPipe.Reader.Complete();
Internal\Http\HttpProtocol.FeatureCollection.cs (1)
99((PipeReader)self).Complete();
Internal\Http2\Http2Connection.cs (1)
496Input.Complete();
Internal\Http2\Http2MessageBody.cs (2)
134_context.RequestBodyPipe.Reader.Complete(); 155_context.RequestBodyPipe.Reader.Complete();
Internal\Http2\Http2Stream.cs (1)
178RequestBodyPipe.Reader.Complete();
Internal\Http3\Http3ControlStream.cs (2)
112Input.Complete(abortReason); 125Input.Complete();
Internal\Http3\Http3MessageBody.cs (2)
102_context.RequestBodyPipe.Reader.Complete(); 123_context.RequestBodyPipe.Reader.Complete();
Internal\Http3\Http3PendingStream.cs (1)
36Context.Transport.Input.Complete(exception);
Internal\Http3\Http3Stream.cs (1)
589RequestBodyPipe.Reader.Complete();
Internal\WebTransport\WebTransportStream.cs (1)
90_duplexPipe.Input.Complete(abortReason);
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (2)
Internal\NamedPipeConnection.cs (2)
202Output.Complete(unexpectedError); 282_originalTransport.Input.Complete();
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (3)
Internal\QuicStreamContext.cs (2)
476Output.Complete(unexpectedError); 557_originalTransport.Input.Complete();
src\aspnetcore\src\Servers\Kestrel\shared\CompletionPipeReader.cs (1)
44_inner.Complete(exception);
Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets (2)
Internal\SocketConnection.cs (2)
104_originalTransport.Input.Complete(); 339Output.Complete(unexpectedError);
Microsoft.AspNetCore.TestHost (1)
ResponseBodyReaderStream.cs (1)
145_pipe.Reader.Complete();
System.IO.Pipelines (3)
System\IO\Pipelines\Pipe.cs (1)
1250Reader.Complete(ThrowHelper.CreateInvalidOperationException_NoConcurrentOperation());
System\IO\Pipelines\PipeReader.cs (1)
132Complete(exception);
System\IO\Pipelines\PipeReaderStream.cs (1)
27_pipeReader.Complete();