FlushAsync

Internal\Http\HttpResponsePipeWriter.cs (1)

46public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default)

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

109public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default)

Internal\Infrastructure\StatusCheckPipeWriter.cs (1)

58public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default)

Internal\Infrastructure\ThrowingPipeWriter.cs (1)

23public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default) => throw new InvalidOperationException(_message);

Internal\Infrastructure\WrappingPipeWriter.cs (1)

41public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default)

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

52public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default)

ResponseBodyPipeWriter.cs (1)

24public override async ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken)

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

76public override async ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default)

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

32public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default) => _pipe.FlushAsync(cancellationToken);

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

266public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default)

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

76public override async ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default)

Internal\JsonTranscodingServerCallContext.cs (1)

231return HttpContext.Response.BodyWriter.FlushAsync().GetAsTask();

Extensions\HttpResponseWritingExtensions.cs (2)

61return response.BodyWriter.FlushAsync(cancellationToken).GetAsTask(); 68await response.BodyWriter.FlushAsync(cancellationToken);

Internal\Transports\WebSocketsServerTransport.cs (1)

163var flushResult = await _application.Output.FlushAsync();

Internal\LongPollingTransport.cs (1)

198var flushResult = await _application.Output.FlushAsync(cancellationToken).ConfigureAwait(false);

Internal\WebSocketsTransport.cs (1)

489var flushResult = await _application.Output.FlushAsync().ConfigureAwait(false);

Extensions\OpenApiEndpointRouteBuilderExtensions.cs (1)

81await context.Response.BodyWriter.FlushAsync(context.RequestAborted);

OwinFeatureCollection.cs (2)

428await _responseBodyWrapper.FlushAsync(cancellationToken); 439return _responseBodyWrapper.FlushAsync().AsTask();

CacheEntry\CachedResponseBody.cs (1)

30await destination.FlushAsync(cancellationToken);

Core\IISHttpContext.IO.cs (1)

125var result = await _bodyInputPipe.Writer.FlushAsync();

Core\OutputProducer.cs (1)

101var awaitable = pipeWriter.FlushAsync(cancellationToken);

src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

113return _output.FlushAsync(cancellationToken).GetAsTask();

Internal\Http\Http1ChunkedEncodingMessageBody.cs (1)

132await _requestBodyPipe.Writer.FlushAsync();

Internal\Http\Http1Connection.cs (2)

1106return _context.Transport.Output.FlushAsync().GetAsTask(); 1126return output.FlushAsync().GetAsTask();

Internal\Http2\Http2Connection.cs (1)

1914var result = await writer.FlushAsync();

Internal\Http2\Http2Stream.cs (1)

512var flushTask = RequestBodyPipe.Writer.FlushAsync();

Internal\Http3\Http3FrameWriter.cs (3)

127return _outputWriter.FlushAsync().GetAsTask(); 157return _outputWriter.FlushAsync().GetAsTask(); 250return _outputWriter.FlushAsync();

Internal\Http3\Http3Stream.cs (1)

969return RequestBodyPipe.Writer.FlushAsync().GetAsTask();

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

121var flushTask = _innerPipeWriter.FlushAsync(cancellationToken); 173flushTask = _innerPipeWriter.FlushAsync(cancellationToken);

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

60var pipeFlushTask = _writer.FlushAsync(cancellationToken);

Internal\Infrastructure\StatusCheckPipeWriter.cs (1)

61return _inner.FlushAsync(cancellationToken);

Internal\Infrastructure\WrappingPipeWriter.cs (1)

43return _inner.FlushAsync(cancellationToken);

src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

113return _output.FlushAsync(cancellationToken).GetAsTask();

Internal\QuicStreamContext.cs (1)

251flushTask = input.FlushAsync();

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

54return _inner.FlushAsync(cancellationToken);

HubConnection.cs (2)

1395await connectionState.Connection.Transport.Output.FlushAsync(cancellationToken).ConfigureAwait(false); 1673var sendHandshakeResult = await startingConnectionState.Connection.Transport.Output.FlushAsync(CancellationToken.None).ConfigureAwait(false);

src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (2)

111await _writer.FlushAsync().ConfigureAwait(false); 295finalResult = await _writer.FlushAsync().ConfigureAwait(false);

HubConnectionContext.cs (2)

373return _connectionContext.Transport.Output.FlushAsync(cancellationToken); 559await _connectionContext.Transport.Output.FlushAsync();

src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (2)

111await _writer.FlushAsync().ConfigureAwait(false); 295finalResult = await _writer.FlushAsync().ConfigureAwait(false);

ResponseBodyPipeWriter.cs (1)

30return await _pipe.Writer.FlushAsync(cancellationToken);

Logging\Internal\HttpResponseBodyReader.cs (1)

162FlushResult result = await writer.FlushAsync(cancellationToken).ConfigureAwait(false);

System\IO\Pipelines\FlushResult.cs (4)

System\IO\Pipelines\PipeOptions.cs (7)

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

35/// <summary>Cancels the pending <see cref="System.IO.Pipelines.PipeWriter.FlushAsync(System.Threading.CancellationToken)" /> or <see cref="System.IO.Pipelines.PipeWriter.WriteAsync(System.ReadOnlyMemory{byte},System.Threading.CancellationToken)" /> operation without causing the operation to throw and without completing the <see cref="System.IO.Pipelines.PipeWriter" />. If there is no pending operation, this cancels the next operation.</summary> 36/// <remarks>The canceled <see cref="System.IO.Pipelines.PipeWriter.FlushAsync(System.Threading.CancellationToken)" /> or <see cref="System.IO.Pipelines.PipeWriter.WriteAsync(System.ReadOnlyMemory{byte},System.Threading.CancellationToken)" /> operation returns a <see cref="System.IO.Pipelines.FlushResult" /> where <see cref="System.IO.Pipelines.FlushResult.IsCanceled" /> is <see langword="true" />.</remarks> 116return FlushAsync(cancellationToken); 137FlushResult result = await FlushAsync(cancellationToken).ConfigureAwait(false);

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

95ValueTask<FlushResult> valueTask = _pipeWriter.FlushAsync(cancellationToken);

System\Text\Json\Serialization\JsonSerializer.Write.Pipe.cs (1)

287FlushResult result = await utf8Json.FlushAsync(cancellationToken).ConfigureAwait(false);

System\Text\Json\Serialization\Metadata\JsonTypeInfoOfT.WriteHelpers.cs (2)

121FlushResult result = await pipeWriter.FlushAsync(cancellationToken).ConfigureAwait(false); 183FlushResult result = await pipeWriter.FlushAsync(cancellationToken).ConfigureAwait(false);