FlushAsync

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

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

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

54public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default) => _output.FlushAsync(cancellationToken);

EndToEndBenchmarks.cs (1)

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

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)

ConcurrentPipeWriterTests.cs (1)

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

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

54public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default) => _output.FlushAsync(cancellationToken);

Mocks\NullPipeWriter.cs (1)

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

ResponseHeadersWritingBenchmark.cs (1)

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

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

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

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

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

Shared\TestPipeWriter.cs (1)

39public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = new CancellationToken())

ResponseBodyPipeWriter.cs (1)

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

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

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

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

54public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default) => _output.FlushAsync(cancellationToken);

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

158public override 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\libraries\Common\src\System\Text\Json\PooledByteBufferWriter.cs (1)

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

Tcp\TcpConnection.cs (1)

174var result = await _application.Output.FlushAsync();

src\Shared\Http2cat\Http2Utilities.cs (1)

398await writableBuffer.FlushAsync().AsTask().DefaultTimeout();

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

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

src\Shared\Http2cat\Http2Utilities.cs (1)

398await writableBuffer.FlushAsync().AsTask().DefaultTimeout();

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

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

src\Shared\Http2cat\Http2Utilities.cs (1)

398await writableBuffer.FlushAsync().AsTask().DefaultTimeout();

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

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

src\Shared\Http2cat\Http2Utilities.cs (1)

398await writableBuffer.FlushAsync().AsTask().DefaultTimeout();

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

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

src\Shared\Http2cat\Http2Utilities.cs (1)

398await writableBuffer.FlushAsync().AsTask().DefaultTimeout();

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

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

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

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

src\Shared\Http2cat\Http2Utilities.cs (1)

398await writableBuffer.FlushAsync().AsTask().DefaultTimeout();

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

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

ChunkedResponseTests.cs (10)

206await httpContext.Response.BodyWriter.FlushAsync(); 247await httpContext.Response.BodyWriter.FlushAsync(); 588await response.BodyWriter.FlushAsync(); 631await response.BodyWriter.FlushAsync(); 679await response.BodyWriter.FlushAsync(); 720await response.BodyWriter.FlushAsync(); 735await response.BodyWriter.FlushAsync(); 792await response.BodyWriter.FlushAsync(); 1080await response.BodyWriter.FlushAsync(); 1119await response.BodyWriter.FlushAsync();

ConnectionMiddlewareTests.cs (1)

300await context.Response.BodyWriter.FlushAsync();

Http2\Http2ConnectionTests.cs (1)

1361await context.Response.BodyWriter.FlushAsync();

Http2\Http2StreamTests.cs (9)

3224await context.Response.BodyWriter.FlushAsync(); 3976await response.BodyWriter.FlushAsync(); 4017await response.BodyWriter.FlushAsync(); 4029await response.BodyWriter.FlushAsync(); 4070await response.BodyWriter.FlushAsync(); 4116await response.BodyWriter.FlushAsync(); 4378await response.BodyWriter.FlushAsync(); 4579await response.BodyWriter.FlushAsync(); 5890await response.BodyWriter.FlushAsync();

Http2\Http2TestBase.cs (1)

762await writableBuffer.FlushAsync().AsTask().DefaultTimeout();

Http3\Http3StreamTests.cs (1)

727await context.Response.BodyWriter.FlushAsync();

Http3\WebTransport\WebTransportStreamTests.cs (1)

44await stream.Transport.Output.FlushAsync();

ResponseTests.cs (9)

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

54return _inner.FlushAsync(cancellationToken);

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (1)

511var task = writableBuffer.FlushAsync();

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

54public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default) => _output.FlushAsync(cancellationToken);

src\Servers\Kestrel\shared\test\TestApp.cs (2)

57await response.BodyWriter.FlushAsync(); 75await response.BodyWriter.FlushAsync();

Http3\Http3RequestTests.cs (2)

1074await context.Response.BodyWriter.FlushAsync(); 1092await context.Response.BodyWriter.FlushAsync();

HttpClientHttp2InteropTests.cs (3)

616await context.Response.BodyWriter.FlushAsync(); 708await context.Response.BodyWriter.FlushAsync(); 767await context.Response.BodyWriter.FlushAsync();

Startup.cs (1)

90await response.BodyWriter.FlushAsync();

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);

HttpConnectionManagerTests.cs (1)

128var result = await connection.Transport.Output.FlushAsync();

Extensions\OpenApiEndpointRouteBuilderExtensions.cs (1)

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

EndToEndBenchmarks.cs (1)

103return destination.FlushAsync(cancellationToken).AsTask();

RedisOutputCacheStore.cs (1)

226await destination.FlushAsync(cancellationToken).ConfigureAwait(false);

TestUtils.cs (1)

87await context.Response.BodyWriter.FlushAsync();

OwinFeatureCollection.cs (2)

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

CacheEntry\CachedResponseBody.cs (1)

30await destination.FlushAsync(cancellationToken);

src\Shared\Http2cat\Http2Utilities.cs (1)

398await writableBuffer.FlushAsync().AsTask().DefaultTimeout();

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

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

Core\IISHttpContext.IO.cs (1)

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

Core\OutputProducer.cs (1)

101var awaitable = pipeWriter.FlushAsync(cancellationToken);

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

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

Internal\Http\Http1ChunkedEncodingMessageBody.cs (1)

128await _requestBodyPipe.Writer.FlushAsync();

Internal\Http\Http1Connection.cs (1)

795return _context.Transport.Output.FlushAsync().GetAsTask();

Internal\Http2\Http2Connection.cs (1)

1784var result = await writer.FlushAsync();

Internal\Http2\Http2Stream.cs (1)

498var 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)

907return 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\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

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

BodyControlTests.cs (1)

138await Assert.ThrowsAsync<ObjectDisposedException>(async () => await responsePipe.FlushAsync());

BufferWriterTests.cs (2)

27Pipe.Writer.FlushAsync().GetAwaiter().GetResult(); 200Pipe.Writer.FlushAsync().GetAwaiter().GetResult();

ConcurrentPipeWriterTests.cs (10)

Http2\Http2FrameWriterTests.cs (1)

82await pipe.Writer.FlushAsync();

HttpResponsePipeWriterTests.cs (1)

59var ex = Assert.Throws<ObjectDisposedException>(() => { pipeWriter.FlushAsync(); });

PipelineExtensionTests.cs (6)

44writerBuffer.FlushAsync().GetAwaiter().GetResult(); 68writerBuffer.FlushAsync().GetAwaiter().GetResult(); 93pipeWriter.FlushAsync().GetAwaiter().GetResult(); 123writerBuffer.FlushAsync().GetAwaiter().GetResult(); 140writerBuffer.FlushAsync().GetAwaiter().GetResult(); 173writerBuffer.FlushAsync().GetAwaiter().GetResult();

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

54public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default) => _output.FlushAsync(cancellationToken);

src\Servers\Kestrel\shared\test\TestApp.cs (2)

57await response.BodyWriter.FlushAsync(); 75await response.BodyWriter.FlushAsync();

ChunkWriterBenchmark.cs (1)

37var flushResult = _writer.FlushAsync();

PipeThroughputBenchmark.cs (2)

35await _pipe.Writer.FlushAsync(); 60_pipe.Writer.FlushAsync().GetAwaiter().GetResult();

RequestParsingBenchmark.cs (1)

136Pipe.Writer.FlushAsync().GetAwaiter().GetResult();

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

54return _inner.FlushAsync(cancellationToken);

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (1)

511var task = writableBuffer.FlushAsync();

Internal\NamedPipeConnection.cs (1)

99var flushTask = Input.FlushAsync();

Internal\QuicStreamContext.cs (1)

249flushTask = input.FlushAsync();

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

54return _inner.FlushAsync(cancellationToken);

Internal\SocketConnection.cs (1)

172var flushTask = Input.FlushAsync();

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

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

HubConnection.cs (2)

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

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

110await _writer.FlushAsync().ConfigureAwait(false); 287finalResult = await _writer.FlushAsync().ConfigureAwait(false);

HubProtocolVersionTests.cs (1)

144await connectionContext.Transport.Output.FlushAsync().DefaultTimeout();

HubConnectionContext.cs (2)

282return _connectionContext.Transport.Output.FlushAsync(cancellationToken); 449await _connectionContext.Transport.Output.FlushAsync();

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

110await _writer.FlushAsync().ConfigureAwait(false); 287finalResult = await _writer.FlushAsync().ConfigureAwait(false);

HubConnectionHandlerTests.cs (2)

557await client.Connection.Application.Output.FlushAsync(); 608await client.Connection.Application.Output.FlushAsync();

ResponseBodyPipeWriter.cs (1)

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

TestClientTests.cs (3)

176await ctx.Response.BodyWriter.FlushAsync(); 274await ctx.Response.BodyWriter.FlushAsync(); 509await ctx.Response.BodyWriter.FlushAsync();

FormPipeReaderTests.cs (1)

197await bodyPipe.Writer.FlushAsync();

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

54public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default) => _output.FlushAsync(cancellationToken);

src\Servers\Kestrel\shared\test\TestApp.cs (2)

57await response.BodyWriter.FlushAsync(); 75await response.BodyWriter.FlushAsync();

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

947await context.Response.BodyWriter.FlushAsync();

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\Metadata\JsonTypeInfoOfT.WriteHelpers.cs (2)

120FlushResult result = await pipeWriter.FlushAsync(cancellationToken).ConfigureAwait(false); 185FlushResult result = await pipeWriter.FlushAsync(cancellationToken).ConfigureAwait(false);