15 overrides of Complete
InMemory.FunctionalTests (4)
Http3\WebTransport\WebTransportTestUtilities.cs (1)
185public override void Complete(Exception exception = null)
src\Servers\Kestrel\shared\CompletionPipeReader.cs (1)
40public override void Complete(Exception? exception = null)
src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)
76public override void Complete(Exception exception = null) => _input.Complete(exception);
TestTransport\InMemoryTransportConnection.cs (1)
142public override void Complete(Exception exception = null)
Microsoft.AspNetCore.Server.Kestrel.Core (1)
Internal\Http\HttpRequestPipeReader.cs (1)
45public override void Complete(Exception? exception = null)
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (1)
src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)
76public override void Complete(Exception exception = null) => _input.Complete(exception);
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (1)
src\Servers\Kestrel\shared\CompletionPipeReader.cs (1)
40public override void Complete(Exception? exception = null)
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (1)
src\Servers\Kestrel\shared\CompletionPipeReader.cs (1)
40public override void Complete(Exception? exception = null)
Microsoft.AspNetCore.SignalR.Microbenchmarks (1)
Shared\TestPipeReader.cs (1)
30public override void Complete(Exception exception = null)
Microsoft.AspNetCore.SignalR.Tests (1)
HubConnectionHandlerTests.cs (1)
2953public override void Complete(Exception exception = null) =>
Sockets.FunctionalTests (2)
src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)
76public override void Complete(Exception exception = null) => _input.Complete(exception);
src\Servers\Kestrel\test\FunctionalTests\ConnectionMiddlewareTests.cs (1)
112public 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)
166public override void Complete(Exception? exception = null)
85 references to Complete
Aspire.Hosting (1)
Dcp\DcpHostService.cs (1)
372reader.Complete();
ClientSample (2)
Tcp\TcpConnection.cs (2)
52Transport?.Input.Complete(); 105_application.Input.Complete(sendError);
InMemory.FunctionalTests (12)
ChunkedRequestTests.cs (3)
977httpContext.Request.BodyReader.Complete(); 1027request.BodyReader.Complete(); 1090httpContext.Request.BodyReader.Complete(new Exception());
Http2\TlsTests.cs (1)
76reader.Complete();
RequestTests.cs (3)
1963httpContext.Request.BodyReader.Complete(); 2005httpContext.Request.BodyReader.Complete(); 2048httpContext.Request.BodyReader.Complete(new Exception());
src\Servers\Kestrel\shared\CompletionPipeReader.cs (1)
44_inner.Complete(exception);
src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)
76public override void Complete(Exception exception = null) => _input.Complete(exception);
TestTransport\InMemoryConnection.cs (1)
36TransportConnection.Output.Complete();
TestTransport\InMemoryTransportConnection.cs (2)
85Transport.Input.Complete(); 144_reader.Complete(exception);
Microsoft.AspNetCore.Http (1)
Features\RequestBodyPipeFeature.cs (1)
43((PipeReader)self).Complete();
Microsoft.AspNetCore.Http.Connections (5)
Internal\HttpConnectionContext.cs (4)
342Transport?.Input.Complete(); 357Application?.Input.Complete(); 367Application?.Input.Complete(); 384Transport?.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)
101_bodyInputPipe?.Reader.Complete();
Microsoft.AspNetCore.Server.Kestrel.Core (12)
Internal\Http\Http1ChunkedEncodingMessageBody.cs (1)
170_requestBodyPipe.Reader.Complete();
Internal\Http\HttpProtocol.FeatureCollection.cs (1)
99((PipeReader)self).Complete();
Internal\Http2\Http2Connection.cs (1)
492Input.Complete();
Internal\Http2\Http2MessageBody.cs (2)
133_context.RequestBodyPipe.Reader.Complete(); 154_context.RequestBodyPipe.Reader.Complete();
Internal\Http2\Http2Stream.cs (1)
179RequestBodyPipe.Reader.Complete();
Internal\Http3\Http3ControlStream.cs (2)
99Input.Complete(abortReason); 112Input.Complete();
Internal\Http3\Http3MessageBody.cs (2)
101_context.RequestBodyPipe.Reader.Complete(); 122_context.RequestBodyPipe.Reader.Complete();
Internal\Http3\Http3PendingStream.cs (1)
36Context.Transport.Input.Complete(exception);
Internal\WebTransport\WebTransportStream.cs (1)
90_duplexPipe.Input.Complete(abortReason);
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (20)
BodyControlTests.cs (2)
103Assert.Throws<Exception>(() => requestPipe.Complete())); 119Assert.Throws<ObjectDisposedException>(() => requestPipe.Complete());
BufferWriterTests.cs (1)
22Pipe.Reader.Complete();
Http1\Http1ConnectionTests.cs (1)
828_application.Input.Complete();
Http1\Http1ConnectionTestsBase.cs (2)
70_transport.Input.Complete(); 73_application.Input.Complete();
Http1\Http1OutputProducerTests.cs (3)
54socketOutput.Pipe.Reader.Complete(); 83socketOutput.Pipe.Reader.Complete(); 114socketOutput.Pipe.Reader.Complete();
MessageBodyTests.cs (6)
1177reader.Complete(); 1200reader.Complete(); 1314reader.Complete(); 1338reader.Complete(); 1364reader.Complete(); 1390reader.Complete();
PipelineExtensionTests.cs (1)
28_pipe.Reader.Complete();
src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)
76public override void Complete(Exception exception = null) => _input.Complete(exception);
StartLineTests.cs (1)
545Transport.Input.Complete();
TestHelpers\TestInput.cs (2)
84Application.Input.Complete(); 86Transport.Input.Complete();
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (1)
src\Servers\Kestrel\shared\CompletionPipeReader.cs (1)
44_inner.Complete(exception);
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)
473Output.Complete(unexpectedError); 553_originalTransport.Input.Complete();
src\Servers\Kestrel\shared\CompletionPipeReader.cs (1)
44_inner.Complete(exception);
Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets (2)
Internal\SocketConnection.cs (2)
103_originalTransport.Input.Complete(); 338Output.Complete(unexpectedError);
Microsoft.AspNetCore.SignalR.Client.Tests (4)
HubConnectionTests.ConnectionLifecycle.cs (1)
174testConnection.Transport.Input.Complete();
TestConnection.cs (1)
211Transport.Input.Complete();
TestTransport.cs (2)
81Application.Input.Complete(); 88_transport.Input.Complete();
Microsoft.AspNetCore.SignalR.Microbenchmarks (1)
BroadcastBenchmark.cs (1)
91application.Input.Complete();
Microsoft.AspNetCore.SignalR.Tests (4)
EndToEndTests.cs (1)
751_application.Input.Complete();
HubConnectionHandlerTests.cs (2)
2954_originalPipeReader.Complete(exception); 5298prevPipe.Complete(new ConnectionResetException(""));
Internal\MessageBufferTests.cs (1)
332pipes.Application.Input.Complete();
Microsoft.AspNetCore.TestHost (1)
ResponseBodyReaderStream.cs (1)
145_pipe.Reader.Complete();
Microsoft.AspNetCore.WebUtilities.Microbenchmarks (1)
FormReaderBenchmark.cs (1)
39pipe.Reader.Complete();
Microsoft.AspNetCore.WebUtilities.Tests (1)
FormPipeReaderTests.cs (1)
542pipe.Reader.Complete();
Sockets.FunctionalTests (1)
src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)
76public override void Complete(Exception exception = null) => _input.Complete(exception);
System.IO.Pipelines (3)
System\IO\Pipelines\Pipe.cs (1)
1139Reader.Complete(ThrowHelper.CreateInvalidOperationException_NoConcurrentOperation());
System\IO\Pipelines\PipeReader.cs (1)
132Complete(exception);
System\IO\Pipelines\PipeReaderStream.cs (1)
27_pipeReader.Complete();