10 overrides of FlushAsync
Microsoft.AspNetCore.Server.Kestrel.Core (5)
Internal\Http\HttpResponsePipeWriter.cs (1)
46
public override ValueTask<FlushResult>
FlushAsync
(CancellationToken cancellationToken = default)
Internal\Infrastructure\PipeWriterHelpers\ConcurrentPipeWriter.cs (1)
109
public override ValueTask<FlushResult>
FlushAsync
(CancellationToken cancellationToken = default)
Internal\Infrastructure\StatusCheckPipeWriter.cs (1)
58
public override ValueTask<FlushResult>
FlushAsync
(CancellationToken cancellationToken = default)
Internal\Infrastructure\ThrowingPipeWriter.cs (1)
23
public override ValueTask<FlushResult>
FlushAsync
(CancellationToken cancellationToken = default) => throw new InvalidOperationException(_message);
Internal\Infrastructure\WrappingPipeWriter.cs (1)
41
public override ValueTask<FlushResult>
FlushAsync
(CancellationToken cancellationToken = default)
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (1)
src\aspnetcore\src\Servers\Kestrel\shared\CompletionPipeWriter.cs (1)
52
public override ValueTask<FlushResult>
FlushAsync
(CancellationToken cancellationToken = default)
Microsoft.Extensions.Logging.Console (1)
src\runtime\src\libraries\Common\src\System\Text\Json\PooledByteBufferWriter.cs (1)
76
public override async ValueTask<FlushResult>
FlushAsync
(CancellationToken cancellationToken = default)
System.IO.Pipelines (2)
System\IO\Pipelines\Pipe.DefaultPipeWriter.cs (1)
32
public override ValueTask<FlushResult>
FlushAsync
(CancellationToken cancellationToken = default) => _pipe.FlushAsync(cancellationToken);
System\IO\Pipelines\StreamPipeWriter.cs (1)
266
public override ValueTask<FlushResult>
FlushAsync
(CancellationToken cancellationToken = default)
System.Text.Json (1)
src\runtime\src\libraries\Common\src\System\Text\Json\PooledByteBufferWriter.cs (1)
76
public override async ValueTask<FlushResult>
FlushAsync
(CancellationToken cancellationToken = default)
45 references to FlushAsync
Microsoft.AspNetCore.Http.Abstractions (2)
Extensions\HttpResponseWritingExtensions.cs (2)
61
return response.BodyWriter.
FlushAsync
(cancellationToken).GetAsTask();
68
await response.BodyWriter.
FlushAsync
(cancellationToken);
Microsoft.AspNetCore.Http.Connections (1)
Internal\Transports\WebSocketsServerTransport.cs (1)
163
var flushResult = await _application.Output.
FlushAsync
();
Microsoft.AspNetCore.ResponseCaching (1)
CacheEntry\CachedResponseBody.cs (1)
30
await destination.
FlushAsync
(cancellationToken);
Microsoft.AspNetCore.Server.Kestrel.Core (15)
Internal\Http\Http1ChunkedEncodingMessageBody.cs (1)
132
await _requestBodyPipe.Writer.
FlushAsync
();
Internal\Http\Http1Connection.cs (2)
1080
return _context.Transport.Output.
FlushAsync
().GetAsTask();
1100
return output.
FlushAsync
().GetAsTask();
Internal\Http2\Http2Connection.cs (1)
1914
var result = await writer.
FlushAsync
();
Internal\Http2\Http2Stream.cs (1)
509
var flushTask = RequestBodyPipe.Writer.
FlushAsync
();
Internal\Http3\Http3FrameWriter.cs (3)
127
return _outputWriter.
FlushAsync
().GetAsTask();
157
return _outputWriter.
FlushAsync
().GetAsTask();
250
return _outputWriter.
FlushAsync
();
Internal\Http3\Http3Stream.cs (1)
969
return RequestBodyPipe.Writer.
FlushAsync
().GetAsTask();
Internal\Infrastructure\PipeWriterHelpers\ConcurrentPipeWriter.cs (2)
121
var flushTask = _innerPipeWriter.
FlushAsync
(cancellationToken);
173
flushTask = _innerPipeWriter.
FlushAsync
(cancellationToken);
Internal\Infrastructure\PipeWriterHelpers\TimingPipeFlusher.cs (1)
60
var pipeFlushTask = _writer.
FlushAsync
(cancellationToken);
Internal\Infrastructure\StatusCheckPipeWriter.cs (1)
61
return _inner.
FlushAsync
(cancellationToken);
Internal\Infrastructure\WrappingPipeWriter.cs (1)
43
return _inner.
FlushAsync
(cancellationToken);
src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)
113
return _output.
FlushAsync
(cancellationToken).GetAsTask();
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (2)
Internal\QuicStreamContext.cs (1)
249
flushTask = input.
FlushAsync
();
src\aspnetcore\src\Servers\Kestrel\shared\CompletionPipeWriter.cs (1)
54
return _inner.
FlushAsync
(cancellationToken);
Microsoft.AspNetCore.SignalR.Core (4)
HubConnectionContext.cs (2)
300
return _connectionContext.Transport.Output.
FlushAsync
(cancellationToken);
486
await _connectionContext.Transport.Output.
FlushAsync
();
src\aspnetcore\src\SignalR\common\Shared\MessageBuffer.cs (2)
111
await _writer.
FlushAsync
().ConfigureAwait(false);
295
finalResult = await _writer.
FlushAsync
().ConfigureAwait(false);
Microsoft.Extensions.Http.Diagnostics (1)
Logging\Internal\HttpResponseBodyReader.cs (1)
162
FlushResult result = await writer.
FlushAsync
(cancellationToken).ConfigureAwait(false);
System.IO.Pipelines (16)
System\IO\Pipelines\FlushResult.cs (4)
6
/// <summary>Result returned by <see cref="System.IO.Pipelines.PipeWriter.
FlushAsync
(System.Threading.CancellationToken)" /> call.</summary>
12
/// <param name="isCanceled"><see langword="true" /> to indicate the current <see cref="System.IO.Pipelines.PipeWriter.
FlushAsync
(System.Threading.CancellationToken)" /> operation that produced this <see cref="System.IO.Pipelines.FlushResult" /> was canceled by <see cref="System.IO.Pipelines.PipeWriter.CancelPendingFlush" />; otherwise, <see langword="false" />.</param>
29
/// <summary>Gets a value that indicates whether the current <see cref="System.IO.Pipelines.PipeWriter.
FlushAsync
(System.Threading.CancellationToken)" /> operation was canceled by <see cref="System.IO.Pipelines.PipeWriter.CancelPendingFlush" />.</summary>
30
/// <value><see langword="true" /> if the current <see cref="System.IO.Pipelines.PipeWriter.
FlushAsync
(System.Threading.CancellationToken)" /> operation was canceled by <see cref="System.IO.Pipelines.PipeWriter.CancelPendingFlush" />; otherwise, <see langword="false" />.</value>
System\IO\Pipelines\PipeOptions.cs (7)
22
/// <param name="pauseWriterThreshold">The number of bytes in the <see cref="System.IO.Pipelines.Pipe" /> before <see cref="System.IO.Pipelines.PipeWriter.
FlushAsync
(System.Threading.CancellationToken)" /> starts blocking. A value of zero prevents <see cref="System.IO.Pipelines.PipeWriter.
FlushAsync
(System.Threading.CancellationToken)" /> from ever blocking, effectively making the number of bytes in the <see cref="System.IO.Pipelines.Pipe" /> unlimited.</param>
23
/// <param name="resumeWriterThreshold">The number of bytes in the <see cref="System.IO.Pipelines.Pipe" /> when <see cref="System.IO.Pipelines.PipeWriter.
FlushAsync
(System.Threading.CancellationToken)" /> stops blocking.</param>
92
/// <summary>Gets the number of bytes in the <see cref="System.IO.Pipelines.Pipe" /> when <see cref="System.IO.Pipelines.PipeWriter.
FlushAsync
(System.Threading.CancellationToken)" /> starts blocking.</summary>
93
/// <value>The number of bytes in the <see cref="System.IO.Pipelines.Pipe" /> when <see cref="System.IO.Pipelines.PipeWriter.
FlushAsync
(System.Threading.CancellationToken)" /> starts blocking.</value>
96
/// <summary>Gets the number of bytes in the <see cref="System.IO.Pipelines.Pipe" /> when <see cref="System.IO.Pipelines.PipeWriter.
FlushAsync
(System.Threading.CancellationToken)" /> stops blocking.</summary>
97
/// <value>The number of bytes in the <see cref="System.IO.Pipelines.Pipe" /> when <see cref="System.IO.Pipelines.PipeWriter.
FlushAsync
(System.Threading.CancellationToken)" /> stops blocking.</value>
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>
116
return
FlushAsync
(cancellationToken);
137
FlushResult result = await
FlushAsync
(cancellationToken).ConfigureAwait(false);
System\IO\Pipelines\PipeWriterStream.cs (1)
95
ValueTask<FlushResult> valueTask = _pipeWriter.
FlushAsync
(cancellationToken);
System.Text.Json (3)
System\Text\Json\Serialization\JsonSerializer.Write.Pipe.cs (1)
287
FlushResult result = await utf8Json.
FlushAsync
(cancellationToken).ConfigureAwait(false);
System\Text\Json\Serialization\Metadata\JsonTypeInfoOfT.WriteHelpers.cs (2)
121
FlushResult result = await pipeWriter.
FlushAsync
(cancellationToken).ConfigureAwait(false);
183
FlushResult result = await pipeWriter.
FlushAsync
(cancellationToken).ConfigureAwait(false);