CompleteAsync

8 overrides of CompleteAsync

InMemory.FunctionalTests (1)

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

40public override ValueTask CompleteAsync(Exception? exception = null)

Microsoft.AspNetCore.OutputCaching.Microbenchmarks (1)

EndToEndBenchmarks.cs (1)

283public override ValueTask CompleteAsync(Exception? exception = null) => default;

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

Internal\Http\HttpResponsePipeWriter.cs (1)

40public override ValueTask CompleteAsync(Exception? exception = null)

Internal\Infrastructure\StatusCheckPipeWriter.cs (1)

82public override ValueTask CompleteAsync(Exception? exception = null)

Internal\Infrastructure\WrappingPipeWriter.cs (1)

61public override ValueTask CompleteAsync(Exception? exception = null)

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

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

40public override ValueTask CompleteAsync(Exception? exception = null)

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

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

40public override ValueTask CompleteAsync(Exception? exception = null)

System.IO.Pipelines (1)

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

237public override async ValueTask CompleteAsync(Exception? exception = null)

49 references to CompleteAsync

http2cat (1)

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)

52await Output.CompleteAsync();

IIS.FunctionalTests (1)

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)

52await Output.CompleteAsync();

IIS.LongTests (1)

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)

52await Output.CompleteAsync();

IIS.NewHandler.FunctionalTests (1)

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)

52await Output.CompleteAsync();

IIS.NewShim.FunctionalTests (1)

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)

52await Output.CompleteAsync();

IIS.ShadowCopy.Tests (1)

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)

52await Output.CompleteAsync();

IISExpress.FunctionalTests (1)

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)

52await Output.CompleteAsync();

InMemory.FunctionalTests (2)

ResponseTests.cs (1)

3877await httpContext.Response.BodyWriter.CompleteAsync();

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

44return _inner.CompleteAsync(exception);

Microsoft.AspNetCore.Components.Server (1)

Circuits\RemoteJSDataStream.cs (1)

219await _pipe.Writer.CompleteAsync(ex);

Microsoft.AspNetCore.Http (1)

StreamResponseBodyFeature.cs (1)

137await _pipeWriter.CompleteAsync();

Microsoft.AspNetCore.OutputCaching.Tests (2)

CachedResponseBodyTests.cs (2)

35var copyTask = RecyclableReadOnlySequenceSegment.CopyToAsync(body, pipe.Writer, cts.Token).AsTask().ContinueWith(t => pipe.Writer.CompleteAsync(t.Exception)); 93await writer.CompleteAsync();

Microsoft.AspNetCore.ResponseCaching.Microbenchmarks (3)

ResponseCachingBenchmark.cs (3)

65await pipe.Writer.CompleteAsync(); 80await pipe.Writer.CompleteAsync(); 123public Task CompleteAsync() => Writer.CompleteAsync().AsTask();

Microsoft.AspNetCore.ResponseCaching.Tests (2)

CachedResponseBodyTests.cs (2)

43var copyTask = body.CopyToAsync(pipe.Writer, cts.Token).ContinueWith(_ => pipe.Writer.CompleteAsync()); 98await writer.CompleteAsync();

Microsoft.AspNetCore.ResponseCompression (1)

ResponseCompressionBody.cs (1)

50await _pipeAdapter.CompleteAsync();

Microsoft.AspNetCore.Server.HttpSys (1)

RequestProcessing\RequestContext.FeatureCollection.cs (1)

519await _pipeWriter.CompleteAsync();

Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (1)

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)

52await Output.CompleteAsync();

Microsoft.AspNetCore.Server.IIS (3)

Core\IISHttpContext.FeatureCollection.cs (1)

224var completeAsyncValueTask = ResponsePipeWrapper.CompleteAsync();

Core\IISHttpContextOfT.cs (1)

61await ResponsePipeWrapper.CompleteAsync();

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)

52await Output.CompleteAsync();

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

Internal\Http\Http1ChunkedEncodingMessageBody.cs (1)

158await _requestBodyPipe.Writer.CompleteAsync(error);

Internal\Http2\Http2Connection.cs (1)

1893await writer.CompleteAsync(error);

Internal\Http3\Http3FrameWriter.cs (1)

421return _outputWriter.CompleteAsync();

Internal\Http3\Http3Stream.cs (1)

748return RequestBodyPipe.Writer.CompleteAsync();

Internal\Infrastructure\StatusCheckPipeWriter.cs (1)

85return _inner.CompleteAsync(exception);

Internal\Infrastructure\WrappingPipeWriter.cs (1)

63return _inner.CompleteAsync(exception);

Internal\WebTransport\WebTransportStream.cs (1)

117await _duplexPipe.Output.CompleteAsync();

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)

52await Output.CompleteAsync();

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

ConcurrentPipeWriterTests.cs (5)

71completeTask = concurrentPipeWriter.CompleteAsync(completeEx); 161completeTask = concurrentPipeWriter.CompleteAsync(completeEx); 253completeTask = concurrentPipeWriter.CompleteAsync(completeEx); 315completeTask = concurrentPipeWriter.CompleteAsync(completeEx); 404completeTask = concurrentPipeWriter.CompleteAsync(completeEx);

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

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

44return _inner.CompleteAsync(exception);

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

Internal\QuicStreamContext.cs (1)

233var completeTask = input.CompleteAsync();

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

44return _inner.CompleteAsync(exception);

Microsoft.AspNetCore.Server.Kestrel.Transport.Quic.Tests (2)

QuicConnectionContextTests.cs (1)

637await serverStream.Transport.Output.CompleteAsync();

QuicTestHelpers.cs (1)

165await serverStream.Transport.Output.CompleteAsync();

Microsoft.AspNetCore.Shared.Tests (1)

src\Shared\ServerInfrastructure\DuplexPipeStreamAdapter.cs (1)

52await Output.CompleteAsync();

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

TestConnection.cs (1)

161await Application.Output.CompleteAsync();

Microsoft.AspNetCore.TestHost (2)

ClientHandler.cs (1)

106await writer.CompleteAsync();

ResponseFeature.cs (1)

150return Writer.CompleteAsync().AsTask();

Microsoft.CodeAnalysis.Remote.Workspaces (2)

RemoteCallback.cs (1)

171await pipeWriter.CompleteAsync(exception).ConfigureAwait(false);

SolutionAssetProvider.cs (1)

62await pipeWriter.CompleteAsync(exception).ConfigureAwait(false);

System.IO.Pipelines (1)

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

34return _pipeWriter.CompleteAsync();