Complete

22 overrides of Complete

InMemory.FunctionalTests (2)

src\Servers\Kestrel\shared\CompletionPipeWriter.cs (1)

33public override void Complete(Exception? exception = null)

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)

52public override void Complete(Exception exception = null) => _output.Complete(exception);

Microsoft.AspNetCore.OutputCaching.Microbenchmarks (1)

EndToEndBenchmarks.cs (1)

281public override void Complete(Exception? exception = null) { }

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

Internal\Http\HttpResponsePipeWriter.cs (1)

34public override void Complete(Exception? exception = null)

Internal\Infrastructure\PipeWriterHelpers\ConcurrentPipeWriter.cs (1)

193public override void Complete(Exception? exception = null)

Internal\Infrastructure\StatusCheckPipeWriter.cs (1)

52public override void Complete(Exception? exception = null)

Internal\Infrastructure\ThrowingPipeWriter.cs (1)

21public override void Complete(Exception? exception = null) => throw new InvalidOperationException(_message);

Internal\Infrastructure\WrappingPipeWriter.cs (1)

36public override void Complete(Exception? exception = null)

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

ConcurrentPipeWriterTests.cs (1)

457public override void Complete(Exception exception = null)

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)

52public override void Complete(Exception exception = null) => _output.Complete(exception);

Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (3)

Mocks\NullPipeWriter.cs (1)

24public override void Complete(Exception exception = null)

ResponseHeadersWritingBenchmark.cs (1)

205public override void Complete(Exception exception = null) { }

src\Servers\Kestrel\shared\CompletionPipeWriter.cs (1)

33public override void Complete(Exception? exception = null)

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

src\Servers\Kestrel\shared\CompletionPipeWriter.cs (1)

33public override void Complete(Exception? exception = null)

Microsoft.AspNetCore.SignalR.Microbenchmarks (1)

Shared\TestPipeWriter.cs (1)

34public override void Complete(Exception exception = null)

Microsoft.AspNetCore.TestHost (1)

ResponseBodyPipeWriter.cs (1)

70public override void Complete(Exception? exception = null)

Microsoft.Extensions.Logging.Console (1)

src\libraries\Common\src\System\Text\Json\PooledByteBufferWriter.cs (1)

237public override void Complete(Exception? exception = null) => throw new NotImplementedException();

Sockets.FunctionalTests (2)

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)

52public override void Complete(Exception exception = null) => _output.Complete(exception);

src\Servers\Kestrel\test\FunctionalTests\ConnectionMiddlewareTests.cs (1)

147public override void Complete(Exception exception = null)

System.IO.Pipelines (2)

System\IO\Pipelines\Pipe.DefaultPipeWriter.cs (1)

22public override void Complete(Exception? exception = null) => _pipe.CompleteWriter(exception);

System\IO\Pipelines\StreamPipeWriter.cs (1)

213public override void Complete(Exception? exception = null)

System.Text.Json (1)

src\libraries\Common\src\System\Text\Json\PooledByteBufferWriter.cs (1)

237public override void Complete(Exception? exception = null) => throw new NotImplementedException();

139 references to Complete

ClientSample (2)

Tcp\TcpConnection.cs (2)

51Transport?.Output.Complete(); 153_application.Output.Complete(error);

InMemory.FunctionalTests (21)

Http2\Http2StreamTests.cs (4)

4638context.Response.BodyWriter.Complete(); 4670context.Response.BodyWriter.Complete(); 4704context.Response.BodyWriter.Complete(expectedException); 5386var ex = Assert.Throws<InvalidOperationException>(() => context.Response.BodyWriter.Complete());

Http2\PipeReaderFactory.cs (2)

45pipe.Writer.Complete(ex); 48pipe.Writer.Complete();

Http3\Http3StreamTests.cs (1)

1662var ex = Assert.Throws<InvalidOperationException>(() => context.Response.BodyWriter.Complete());

ResponseTests.cs (7)

1174completeEx = Assert.Throws<InvalidOperationException>(() => httpContext.Response.BodyWriter.Complete()); 3817httpContext.Response.BodyWriter.Complete(); 3845httpContext.Response.BodyWriter.Complete(); 4116httpContext.Response.BodyWriter.Complete(expectedException); 4145httpContext.Response.BodyWriter.Complete(); 4176httpContext.Response.BodyWriter.Complete(); 4274httpContext.Response.BodyWriter.Complete();

src\Servers\Kestrel\shared\CompletionPipeWriter.cs (1)

37_inner.Complete(exception);

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)

52public override void Complete(Exception exception = null) => _output.Complete(exception);

TestTransport\InMemoryConnection.cs (3)

23TransportConnection.Input.Complete(new ConnectionResetException(string.Empty)); 29TransportConnection.Input.Complete(); 35TransportConnection.Input.Complete();

TestTransport\InMemoryTransportConnection.cs (2)

57Input.Complete(abortReason); 86Transport.Output.Complete();

Microsoft.AspNetCore.Http (1)

StreamResponseBodyFeature.cs (1)

61_pipeWriter.Complete();

Microsoft.AspNetCore.Http.Connections (9)

Internal\HttpConnectionContext.cs (5)

324Application?.Output.Complete(); 341Transport?.Output.Complete(applicationTask.Exception?.InnerException); 356Application?.Output.Complete(); 366Application?.Output.Complete(transportTask.Exception?.InnerException); 383Transport?.Output.Complete();

Internal\HttpConnectionDispatcher.cs (2)

264connection.Transport.Output.Complete(connection.ApplicationTask.Exception); 515connection.Application.Output.Complete();

Internal\Transports\WebSocketsServerTransport.cs (2)

187_application.Output.Complete(ex); 195_application.Output.Complete();

Microsoft.AspNetCore.Http.Connections.Client (8)

Internal\LongPollingTransport.cs (2)

135_transport!.Output.Complete(); 222_application.Output.Complete(_error);

Internal\ServerSentEventsTransport.cs (2)

167_application.Output.Complete(_error); 184_transport!.Output.Complete();

Internal\WebSocketsTransport.cs (4)

427_application.Output.Complete(); 509_application.Output.Complete(ex); 523_application.Output.Complete(); 666_transport!.Output.Complete();

Microsoft.AspNetCore.Http.Connections.Tests (22)

HttpConnectionDispatcherTests.cs (5)

734connection.Transport.Output.Complete(); 2747connection.Transport.Output.Complete(new InvalidOperationException()); 2833connection.Transport.Output.Complete(); 3131connection.Transport.Output.Complete(); 4034_writer.Complete();

LongPollingTests.cs (3)

32connection.Transport.Output.Complete(); 76connection.Transport.Output.Complete(); 102connection.Transport.Output.Complete();

ServerSentEventsTests.cs (5)

30connection.Transport.Output.Complete(); 53connection.Transport.Output.Complete(); 77connection.Transport.Output.Complete(); 102connection.Transport.Output.Complete(); 126connection.Transport.Output.Complete();

WebSocketsTests.cs (9)

59connection.Transport.Output.Complete(); 96connection.Transport.Output.Complete(); 142connection.Transport.Output.Complete(); 188connection.Transport.Output.Complete(new InvalidOperationException("Catastrophic failure.")); 222connection.Transport.Output.Complete(); 259connection.Transport.Output.Complete(new Exception()); 294connection.Transport.Output.Complete(); 335connection.Transport.Output.Complete(); 389connection.Transport.Output.Complete();

Microsoft.AspNetCore.Http.Tests (1)

Features\FormFeatureTests.cs (1)

94pipe.Writer.Complete();

Microsoft.AspNetCore.Server.IIS (3)

Core\IISHttpContext.IO.cs (1)

151_bodyInputPipe!.Writer.Complete(error);

Core\OutputProducer.cs (2)

52_pipe.Writer.Complete(); 68_pipe.Writer.Complete();

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

Internal\Http2\Http2Stream.cs (3)

173RequestBodyPipe.Writer.Complete(); 545RequestBodyPipe.Writer.Complete(); 624RequestBodyPipe.Writer.Complete(abortReason);

Internal\Http3\Http3FrameWriter.cs (1)

443_outputWriter.Complete();

Internal\Http3\Http3OutputProducer.cs (2)

79_pipeWriter.Complete(); 407_pipeWriter.Complete();

Internal\Http3\Http3PendingStream.cs (1)

37Context.Transport.Output.Complete(exception);

Internal\Http3\Http3Stream.cs (2)

185RequestBodyPipe.Writer.Complete(exception); 558RequestBodyPipe.Writer.Complete();

Internal\Infrastructure\PipeWriterHelpers\ConcurrentPipeWriter.cs (3)

208_innerPipeWriter.Complete(exception); 298_innerPipeWriter.Complete(); 302_innerPipeWriter.Complete(_completeException);

Internal\Infrastructure\StatusCheckPipeWriter.cs (1)

55_inner.Complete(exception);

Internal\Infrastructure\WrappingPipeWriter.cs (1)

38_inner.Complete(exception);

Internal\WebTransport\WebTransportStream.cs (1)

95_duplexPipe.Output.Complete(abortReason);

Microsoft.AspNetCore.Server.Kestrel.Core.Tests (21)

BodyControlTests.cs (1)

136Assert.Throws<ObjectDisposedException>(() => responsePipe.Complete());

BufferWriterTests.cs (2)

21Pipe.Writer.Complete(); 28Pipe.Writer.Complete();

Http1\Http1ConnectionTests.cs (2)

579_application.Output.Complete(); 667_application.Output.Complete();

Http1\Http1ConnectionTestsBase.cs (2)

71_transport.Output.Complete(); 74_application.Output.Complete();

Http1\Http1OutputProducerTests.cs (3)

53socketOutput.Pipe.Writer.Complete(); 82socketOutput.Pipe.Writer.Complete(); 113socketOutput.Pipe.Writer.Complete();

HttpResponsePipeWriterTests.cs (1)

49var ex = Assert.Throws<ObjectDisposedException>(() => { pipeWriter.Complete(); });

MessageBodyTests.cs (3)

1218input.Application.Output.Complete(); 1251input.Application.Output.Complete(); 1278input.Application.Output.Complete();

PipelineExtensionTests.cs (2)

29_pipe.Writer.Complete(); 112pipeWriter.Complete();

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)

52public override void Complete(Exception exception = null) => _output.Complete(exception);

StartLineTests.cs (1)

546Transport.Output.Complete();

TestHelpers\TestInput.cs (3)

74Application.Output.Complete(); 85Application.Output.Complete(); 87Transport.Output.Complete();

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

Http2\Http2FrameWriterBenchmark.cs (1)

78_pipe.Writer.Complete();

src\Servers\Kestrel\shared\CompletionPipeWriter.cs (1)

37_inner.Complete(exception);

Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (2)

Internal\NamedPipeConnection.cs (2)

142Input.Complete(_shutdownReason ?? error); 283_originalTransport.Output.Complete();

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

Internal\QuicStreamContext.cs (2)

306Input.Complete(ResolveCompleteReceiveException(error)); 554_originalTransport.Output.Complete();

src\Servers\Kestrel\shared\CompletionPipeWriter.cs (1)

37_inner.Complete(exception);

Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets (2)

Internal\SocketConnection.cs (2)

104_originalTransport.Output.Complete(); 257Input.Complete(_shutdownReason ?? error);

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

src\SignalR\common\Shared\MessageBuffer.cs (1)

258_writer.Complete();

Microsoft.AspNetCore.SignalR.Client.Tests (5)

HubConnectionTests.ConnectionLifecycle.cs (1)

627innerConnection.Application.Output.Complete();

TestConnection.cs (2)

201Application.Output.Complete(ex); 212Transport.Output.Complete();

TestTransport.cs (2)

80Application.Output.Complete(); 87_transport.Output.Complete();

Microsoft.AspNetCore.SignalR.Core (1)

src\SignalR\common\Shared\MessageBuffer.cs (1)

258_writer.Complete();

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

src\SignalR\common\testassets\Tests.Utils\TestClient.cs (1)

314Connection.Application.Output.Complete();

Microsoft.AspNetCore.SignalR.Tests (6)

EndToEndTests.cs (1)

750_application.Output.Complete();

HubConnectionHandlerTests.cs (5)

673client.Connection.Application.Output.Complete(); 2719client.Connection.Transport.Output.Complete(); 2765client.Connection.Transport.Output.Complete(); 3118client.Connection.Transport.Output.Complete(); 3569client.Connection.Application.Output.Complete();

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

TestClient.cs (1)

314Connection.Application.Output.Complete();

Microsoft.AspNetCore.TestHost (2)

ResponseBodyPipeWriter.cs (2)

47_pipe.Writer.Complete(new IOException(string.Empty, innerException)); 59_pipe.Writer.Complete();

Microsoft.AspNetCore.WebUtilities.Microbenchmarks (1)

FormReaderBenchmark.cs (1)

36pipe.Writer.Complete();

Microsoft.AspNetCore.WebUtilities.Tests (3)

FormPipeReaderTests.cs (3)

203bodyPipe.Writer.Complete(); 539pipe.Writer.Complete(); 635bodyPipe.Writer.Complete();

Microsoft.CodeAnalysis.Remote.Workspaces (2)

ISolutionAssetProvider.cs (1)

23/// cref="PipeWriter.Complete"/> on it (in the event of failure or success). Failing to do so will lead to hangs on

RemoteCallback.cs (1)

96/// cref="PipeWriter.Complete"/> the <see cref="PipeWriter"/>. If it does not then reading will hang</param>

Sockets.FunctionalTests (1)

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (1)

52public override void Complete(Exception exception = null) => _output.Complete(exception);

System.IO.Pipelines (3)

System\IO\Pipelines\Pipe.cs (1)

926Writer.Complete(ThrowHelper.CreateInvalidOperationException_NoConcurrentOperation());

System\IO\Pipelines\PipeWriter.cs (1)

26Complete(exception);

System\IO\Pipelines\PipeWriterStream.cs (1)

25_pipeWriter.Complete();