FlushResult

22 instantiations of FlushResult

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

Internal\Http\Http1OutputProducer.cs (4)

147return new ValueTask<FlushResult>(new FlushResult(false, true)); 503return new ValueTask<FlushResult>(new FlushResult(false, true)); 523return new ValueTask<FlushResult>(new FlushResult(false, true)); 561return new ValueTask<FlushResult>(new FlushResult(false, true));

Internal\Http2\Http2OutputProducer.cs (2)

271return new ValueTask<FlushResult>(new FlushResult(false, true)); 536return new ValueTask<FlushResult>(new FlushResult(false, true));

Internal\Http3\Http3OutputProducer.cs (2)

178return new ValueTask<FlushResult>(new FlushResult(false, true)); 366return new ValueTask<FlushResult>(new FlushResult(false, true));

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

Internal\QuicStreamContext.cs (2)

240flushTask = ValueTask.FromResult(new FlushResult(isCanceled: false, isCompleted: true)); 312return new FlushResult(isCanceled: false, isCompleted: true);

Microsoft.AspNetCore.SignalR.Core (4)

HubConnectionContext.cs (2)

310return new ValueTask<FlushResult>(new FlushResult(isCanceled: false, isCompleted: true)); 348return new ValueTask<FlushResult>(new FlushResult(isCanceled: false, isCompleted: true));

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

61_completedTCS.SetResult(new()); 261FlushResult finalResult = new();

Microsoft.Extensions.Logging.Console (1)

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

82return new FlushResult(isCanceled: false, isCompleted: false);

System.IO.Pipelines (6)

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

1061return new ValueTask<FlushResult>(new FlushResult(isCanceled: false, isCompleted: true));

System\IO\Pipelines\PipeReader.cs (2)

218return new ValueTask<FlushResult>(new FlushResult(isCanceled: false, isCompleted: false)); 224return new FlushResult(isCanceled: false, isCompleted: false);

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

270return new ValueTask<FlushResult>(new FlushResult(isCanceled: false, isCompleted: false)); 353return new FlushResult(isCanceled: false, isCompleted: false); 367return new FlushResult(isCanceled: true, isCompleted: false);

System.Text.Json (1)

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

82return new FlushResult(isCanceled: false, isCompleted: false);

212 references to FlushResult

Microsoft.AspNetCore.Http (2)

src\aspnetcore\src\Shared\ValueTaskExtensions\ValueTaskExtensions.cs (2)

13public static Task GetAsTask(this in ValueTask<FlushResult> valueTask) 29public static ValueTask GetAsValueTask(this in ValueTask<FlushResult> valueTask)

Microsoft.AspNetCore.Http.Abstractions (2)

src\aspnetcore\src\Shared\ValueTaskExtensions\ValueTaskExtensions.cs (2)

13public static Task GetAsTask(this in ValueTask<FlushResult> valueTask) 29public static ValueTask GetAsValueTask(this in ValueTask<FlushResult> valueTask)

Microsoft.AspNetCore.Http.Connections (5)

Internal\Transports\WebSocketsServerTransport.cs (1)

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

src\aspnetcore\src\Shared\ValueTaskExtensions\ValueTaskExtensions.cs (2)

13public static Task GetAsTask(this in ValueTask<FlushResult> valueTask) 29public static ValueTask GetAsValueTask(this in ValueTask<FlushResult> valueTask)

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

92static async ValueTask WriteSlowAsync(ValueTask<FlushResult> flushTask) 94var flushResult = await flushTask.ConfigureAwait(false);

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

Internal\Http\Http1OutputProducer.cs (17)

106public ValueTask<FlushResult> WriteDataToPipeAsync(ReadOnlySpan<byte> buffer, CancellationToken cancellationToken = default) 110return new ValueTask<FlushResult>(Task.FromCanceled<FlushResult>(cancellationToken)); 116public ValueTask<FlushResult> WriteStreamSuffixAsync() 118ValueTask<FlushResult> result = default; 141public ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default) 147return new ValueTask<FlushResult>(new FlushResult(false, true)); 171static ValueTask<FlushResult> FlushAsyncChunked(Http1OutputProducer producer, CancellationToken token) 295public ValueTask<FlushResult> WriteChunkAsync(ReadOnlySpan<byte> buffer, CancellationToken cancellationToken) 490public ValueTask<FlushResult> Write100ContinueAsync() 495public ValueTask<FlushResult> FirstWriteAsync(int statusCode, string? reasonPhrase, HttpResponseHeaders responseHeaders, ResponseBodyMode responseBodyMode, ReadOnlySpan<byte> buffer, CancellationToken cancellationToken) 503return new ValueTask<FlushResult>(new FlushResult(false, true)); 515public ValueTask<FlushResult> FirstWriteChunkedAsync(int statusCode, string? reasonPhrase, HttpResponseHeaders responseHeaders, ResponseBodyMode responseBodyMode, ReadOnlySpan<byte> buffer, CancellationToken cancellationToken) 523return new ValueTask<FlushResult>(new FlushResult(false, true)); 551private ValueTask<FlushResult> WriteAsync( 561return new ValueTask<FlushResult>(new FlushResult(false, true)); 569private ValueTask<FlushResult> WriteAsyncInternal(

Internal\Http\HttpProtocol.cs (9)

958public ValueTask<FlushResult> ProduceContinueAsync() 1123private async Task WriteSuffixAwaited(ValueTask<FlushResult> writeTask) 1527public ValueTask<FlushResult> FlushPipeAsync(CancellationToken cancellationToken) 1608public ValueTask<FlushResult> WritePipeAsync(ReadOnlyMemory<byte> data, CancellationToken cancellationToken) 1644private ValueTask<FlushResult> FirstWriteAsync(ReadOnlyMemory<byte> data, CancellationToken cancellationToken) 1657private async ValueTask<FlushResult> FirstWriteAsyncAwaited(Task initializeTask, ReadOnlyMemory<byte> data, CancellationToken cancellationToken) 1664private ValueTask<FlushResult> FirstWriteAsyncInternal(ReadOnlyMemory<byte> data, CancellationToken cancellationToken) 1700private async ValueTask<FlushResult> FlushAsyncAwaited(Task initializeTask, CancellationToken cancellationToken) 1711public async ValueTask<FlushResult> WriteAsyncAwaited(Task initializeTask, ReadOnlyMemory<byte> data, CancellationToken cancellationToken)

Internal\Http\HttpResponsePipeWriter.cs (2)

46public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default) 64public override ValueTask<FlushResult> WriteAsync(ReadOnlyMemory<byte> source, CancellationToken cancellationToken = default)

Internal\Http\IHttpOutputProducer.cs (7)

13ValueTask<FlushResult> WriteChunkAsync(ReadOnlySpan<byte> data, CancellationToken cancellationToken); 14ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken); 15ValueTask<FlushResult> Write100ContinueAsync(); 18ValueTask<FlushResult> WriteDataToPipeAsync(ReadOnlySpan<byte> data, CancellationToken cancellationToken); 21ValueTask<FlushResult> WriteStreamSuffixAsync(); 28ValueTask<FlushResult> FirstWriteAsync(int statusCode, string? reasonPhrase, HttpResponseHeaders responseHeaders, ResponseBodyMode responseBodyMode, ReadOnlySpan<byte> data, CancellationToken cancellationToken); 29ValueTask<FlushResult> FirstWriteChunkedAsync(int statusCode, string? reasonPhrase, HttpResponseHeaders responseHeaders, ResponseBodyMode responseBodyMode, ReadOnlySpan<byte> data, CancellationToken cancellationToken);

Internal\Http\IHttpResponseControl.cs (3)

10ValueTask<FlushResult> ProduceContinueAsync(); 15ValueTask<FlushResult> FlushPipeAsync(CancellationToken cancellationToken); 16ValueTask<FlushResult> WritePipeAsync(ReadOnlyMemory<byte> source, CancellationToken cancellationToken);

Internal\Http\IHttpResponsePipeWriterControl.cs (2)

14ValueTask<FlushResult> FlushPipeAsync(CancellationToken cancellationToken); 15ValueTask<FlushResult> WritePipeAsync(ReadOnlyMemory<byte> source, CancellationToken cancellationToken);

Internal\Http\MessageBody.cs (3)

108protected ValueTask<FlushResult> TryProduceContinueAsync() 207ValueTask<FlushResult> continueTask = TryProduceContinueAsync(); 227protected async ValueTask<ReadResult> StartTimingReadAwaited(ValueTask<FlushResult> continueTask, ValueTask<ReadResult> readAwaitable, CancellationToken cancellationToken)

Internal\Http2\Http2Connection.cs (1)

1914var result = await writer.FlushAsync();

Internal\Http2\Http2FrameWriter.cs (17)

238FlushResult flushResult = default; 481private ValueTask<FlushResult> FlushEndOfStreamHeadersAsync(Http2Stream stream) 499public ValueTask<FlushResult> Write100ContinueAsync(int streamId) 563private ValueTask<FlushResult> WriteDataAndTrailersAsync(Http2Stream stream, in ReadOnlySequence<byte> data, bool writeHeaders, HttpResponseTrailers headers) 781private ValueTask<FlushResult> WriteDataAsync(Http2Stream stream, ReadOnlySequence<byte> data, long dataLength, bool endStream, bool writeHeaders) 783var writeTask = default(ValueTask<FlushResult>); 789return ValueTask.FromResult<FlushResult>(default); 830static async ValueTask<FlushResult> FlushAsyncAwaited(ValueTask<FlushResult> writeTask, ITimeoutControl timeoutControl, MinDataRate? minResponseDataRate) 837var flushResult = await writeTask; 852public ValueTask<FlushResult> WriteWindowUpdateAsync(int streamId, int sizeIncrement) 875public ValueTask<FlushResult> WriteRstStreamAsync(int streamId, Http2ErrorCode errorCode) 902public ValueTask<FlushResult> WriteSettingsAsync(List<Http2PeerSetting> settings) 935public ValueTask<FlushResult> WriteSettingsAckAsync() 957public ValueTask<FlushResult> WritePingAsync(Http2PingFrameFlags flags, in ReadOnlySequence<byte> payload) 987public ValueTask<FlushResult> WriteGoAwayAsync(int lastStreamId, Http2ErrorCode errorCode) 1045private ValueTask<FlushResult> TimeFlushUnsynchronizedAsync()

Internal\Http2\Http2MessageBody.cs (1)

49ValueTask<FlushResult> continueTask = TryProduceContinueAsync();

Internal\Http2\Http2OutputProducer.cs (18)

258public ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken) 262return new ValueTask<FlushResult>(Task.FromCanceled<FlushResult>(cancellationToken)); 271return new ValueTask<FlushResult>(new FlushResult(false, true)); 343public ValueTask<FlushResult> Write100ContinueAsync() 417public ValueTask<FlushResult> WriteStreamSuffixAsync() 423return ValueTask.FromResult<FlushResult>(default); 435return ValueTask.FromResult<FlushResult>(default); 439public ValueTask<FlushResult> WriteRstStreamAsync(Http2ErrorCode error) 521public ValueTask<FlushResult> WriteDataToPipeAsync(ReadOnlySpan<byte> data, CancellationToken cancellationToken) 525return new ValueTask<FlushResult>(Task.FromCanceled<FlushResult>(cancellationToken)); 536return new ValueTask<FlushResult>(new FlushResult(false, true)); 552public ValueTask<FlushResult> FirstWriteAsync(int statusCode, string? reasonPhrase, HttpResponseHeaders responseHeaders, ResponseBodyMode responseBodyMode, ReadOnlySpan<byte> data, CancellationToken cancellationToken) 562ValueTask<FlushResult> IHttpOutputProducer.WriteChunkAsync(ReadOnlySpan<byte> data, CancellationToken cancellationToken) 567public ValueTask<FlushResult> FirstWriteChunkedAsync(int statusCode, string? reasonPhrase, HttpResponseHeaders responseHeaders, ResponseBodyMode responseBodyMode, ReadOnlySpan<byte> data, CancellationToken cancellationToken) 623internal ValueTask<FlushResult> CompleteResponseAsync() 626ValueTask<FlushResult> task = default;

Internal\Http3\Http3Connection.cs (1)

762private async ValueTask<FlushResult> SendGoAwayAsync(long id)

Internal\Http3\Http3ControlStream.cs (1)

149internal ValueTask<FlushResult> SendGoAway(long id)

Internal\Http3\Http3FrameWriter.cs (6)

160public ValueTask<FlushResult> WriteDataAsync(in ReadOnlySequence<byte> data) 237internal ValueTask<FlushResult> WriteGoAway(long id) 262public ValueTask<FlushResult> Write100ContinueAsync() 296public ValueTask<FlushResult> WriteResponseTrailersAsync(long streamId, HttpResponseTrailers headers) 329private ValueTask<FlushResult> TimeFlushUnsynchronizedAsync() 337public ValueTask<FlushResult> FlushAsync(IHttpOutputAborter? outputAborter, CancellationToken cancellationToken)

Internal\Http3\Http3OutputProducer.cs (16)

28private ValueTask<FlushResult> _dataWriteProcessingTask; 150public ValueTask<FlushResult> FirstWriteAsync(int statusCode, string? reasonPhrase, HttpResponseHeaders responseHeaders, ResponseBodyMode responseBodyMode, ReadOnlySpan<byte> data, CancellationToken cancellationToken) 160public ValueTask<FlushResult> FirstWriteChunkedAsync(int statusCode, string? reasonPhrase, HttpResponseHeaders responseHeaders, ResponseBodyMode responseBodyMode, ReadOnlySpan<byte> data, CancellationToken cancellationToken) 165public ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken) 169return new ValueTask<FlushResult>(Task.FromCanceled<FlushResult>(cancellationToken)); 178return new ValueTask<FlushResult>(new FlushResult(false, true)); 306public ValueTask<FlushResult> Write100ContinueAsync() 321public ValueTask<FlushResult> WriteChunkAsync(ReadOnlySpan<byte> data, CancellationToken cancellationToken) 351public ValueTask<FlushResult> WriteDataToPipeAsync(ReadOnlySpan<byte> data, CancellationToken cancellationToken) 355return new ValueTask<FlushResult>(Task.FromCanceled<FlushResult>(cancellationToken)); 366return new ValueTask<FlushResult>(new FlushResult(false, true)); 393public ValueTask<FlushResult> WriteStreamSuffixAsync() 410private async ValueTask<FlushResult> ProcessDataWrites() 412FlushResult flushResult = default;

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

44private TaskCompletionSource<FlushResult>? _currentFlushTcs; 109public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default) 113return new ValueTask<FlushResult>(_currentFlushTcs.Task); 134_currentFlushTcs = new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously); 135var result = new ValueTask<FlushResult>(_currentFlushTcs.Task); 143private async Task FlushAsyncAwaited(ValueTask<FlushResult> flushTask, CancellationToken cancellationToken) 151var flushResult = await flushTask; 168_currentFlushTcs = new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously); 288private void CompleteFlushUnsynchronized(FlushResult flushResult, Exception? flushEx)

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

36public ValueTask<FlushResult> FlushAsync() 41public ValueTask<FlushResult> FlushAsync(IHttpOutputAborter? outputAborter, CancellationToken cancellationToken) 46public ValueTask<FlushResult> FlushAsync(MinDataRate? minRate, long count) 51public ValueTask<FlushResult> FlushAsync(MinDataRate? minRate, long count, IHttpOutputAborter? outputAborter, CancellationToken cancellationToken) 64var flushResult = pipeFlushTask.Result; 71return new ValueTask<FlushResult>(flushResult); 77private async ValueTask<FlushResult> TimeFlushAsyncAwaited(ValueTask<FlushResult> pipeFlushTask, MinDataRate? minRate, IHttpOutputAborter? outputAborter, CancellationToken cancellationToken) 86var flushResult = await pipeFlushTask;

Internal\Infrastructure\StatusCheckPipeWriter.cs (2)

58public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default) 88public override ValueTask<FlushResult> WriteAsync(ReadOnlyMemory<byte> source, CancellationToken cancellationToken = default)

Internal\Infrastructure\ThrowingPipeWriter.cs (1)

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

Internal\Infrastructure\WrappingPipeWriter.cs (2)

41public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default) 66public override ValueTask<FlushResult> WriteAsync(ReadOnlyMemory<byte> source, CancellationToken cancellationToken = default)

src\aspnetcore\src\Shared\ValueTaskExtensions\ValueTaskExtensions.cs (2)

13public static Task GetAsTask(this in ValueTask<FlushResult> valueTask) 29public static ValueTask GetAsValueTask(this in ValueTask<FlushResult> valueTask)

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

Internal\QuicStreamContext.cs (3)

224ValueTask<FlushResult> flushTask; 259var result = await flushTask; 309async static ValueTask<FlushResult> AwaitCompleteTaskAsync(ValueTask completeTask)

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

47public override ValueTask<FlushResult> WriteAsync(ReadOnlyMemory<byte> source, CancellationToken cancellationToken = default) 52public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default)

Microsoft.AspNetCore.SignalR.Core (18)

HubConnectionContext.cs (9)

268private ValueTask<FlushResult> WriteCore(HubMessage message, CancellationToken cancellationToken) 276static async ValueTask<FlushResult> WriteAsync(MessageBuffer messageBuffer, HubConnectionContext hubConnectionContext, 290var result = await messageBuffer.WriteAsync(message, linkedToken); 310return new ValueTask<FlushResult>(new FlushResult(isCanceled: false, isCompleted: true)); 314private ValueTask<FlushResult> WriteCore(SerializedHubMessage message, CancellationToken cancellationToken) 323static async ValueTask<FlushResult> WriteAsync(MessageBuffer messageBuffer, HubConnectionContext hubConnectionContext, 329var result = await messageBuffer.WriteAsync(message, linkedToken); 348return new ValueTask<FlushResult>(new FlushResult(isCanceled: false, isCompleted: true)); 352private async Task CompleteWriteAsync(ValueTask<FlushResult> task, CancellationToken cancellationToken)

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

21private static readonly TaskCompletionSource<FlushResult> _completedTCS = new TaskCompletionSource<FlushResult>(); 51private TaskCompletionSource<FlushResult> _resend = _completedTCS; 123public ValueTask<FlushResult> WriteAsync(SerializedHubMessage hubMessage, CancellationToken cancellationToken) 129public ValueTask<FlushResult> WriteAsync(HubMessage hubMessage, CancellationToken cancellationToken) 134private async ValueTask<FlushResult> WriteAsyncCore(Type hubMessageType, ReadOnlyMemory<byte> messageBytes, CancellationToken cancellationToken) 164ValueTask<FlushResult> writeTask; 258var tcs = new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously); 261FlushResult finalResult = new();

Microsoft.Extensions.Http.Diagnostics (1)

Logging\Internal\HttpResponseBodyReader.cs (1)

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

Microsoft.Extensions.Logging.Console (1)

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

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

System.IO.Pipelines (45)

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

11/// <summary>Initializes a new instance of <see cref="System.IO.Pipelines.FlushResult" /> struct setting the <see cref="System.IO.Pipelines.FlushResult.IsCanceled" /> and <see cref="System.IO.Pipelines.FlushResult.IsCompleted" /> flags.</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>

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

363internal ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken) 367return new ValueTask<FlushResult>(Task.FromCanceled<FlushResult>(cancellationToken)); 371ValueTask<FlushResult> result; 382private void PrepareFlushUnsynchronized(out CompletionData completionData, out ValueTask<FlushResult> result, CancellationToken cancellationToken) 392FlushResult flushResult = default; 394result = new ValueTask<FlushResult>(flushResult); 399result = new ValueTask<FlushResult>(_writer, token: 0); 1008internal FlushResult GetFlushAsyncResult() 1010FlushResult result = default; 1039private void GetFlushResult(ref FlushResult result) 1052internal ValueTask<FlushResult> WriteAsync(ReadOnlyMemory<byte> source, CancellationToken cancellationToken) 1061return new ValueTask<FlushResult>(new FlushResult(isCanceled: false, isCompleted: true)); 1066return new ValueTask<FlushResult>(Task.FromCanceled<FlushResult>(cancellationToken)); 1070ValueTask<FlushResult> result;

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

13private sealed class DefaultPipeWriter : PipeWriter, IValueTaskSource<FlushResult> 32public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default) => _pipe.FlushAsync(cancellationToken); 42public FlushResult GetResult(short token) => _pipe.GetFlushAsyncResult(); 48public override ValueTask<FlushResult> WriteAsync(ReadOnlyMemory<byte> source, CancellationToken cancellationToken = default)

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

218return new ValueTask<FlushResult>(new FlushResult(isCanceled: false, isCompleted: false)); 221static async ValueTask<FlushResult> Awaited(ValueTask writeTask) 232private async Task CopyToAsyncCore<TStream>(TStream destination, Func<TStream, ReadOnlyMemory<byte>, CancellationToken, ValueTask<FlushResult>> writeAsync, CancellationToken cancellationToken) 258FlushResult flushResult = await writeAsync(destination, memory, cancellationToken).ConfigureAwait(false);

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

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> 59public abstract ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default); 113public virtual ValueTask<FlushResult> WriteAsync(ReadOnlyMemory<byte> source, CancellationToken cancellationToken = default) 137FlushResult result = await FlushAsync(cancellationToken).ConfigureAwait(false);

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

79ValueTask<FlushResult> valueTask = _pipeWriter.WriteAsync(new ReadOnlyMemory<byte>(buffer, offset, count), cancellationToken); 87ValueTask<FlushResult> valueTask = _pipeWriter.WriteAsync(buffer, cancellationToken); 95ValueTask<FlushResult> valueTask = _pipeWriter.FlushAsync(cancellationToken); 100private static Task GetFlushResultAsTask(ValueTask<FlushResult> valueTask) 104FlushResult result = valueTask.Result; 113static async Task AwaitTask(ValueTask<FlushResult> valueTask) 115FlushResult result = await valueTask.ConfigureAwait(false);

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

336FlushResult flushResult = await destination.WriteAsync(segment.Memory.Slice(segmentIndex), tokenSource.Token).ConfigureAwait(false);

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

266public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default) 270return new ValueTask<FlushResult>(new FlushResult(isCanceled: false, isCompleted: false)); 279public override ValueTask<FlushResult> WriteAsync(ReadOnlyMemory<byte> source, CancellationToken cancellationToken = default) 292private async ValueTask<FlushResult> FlushAsyncInternal(bool writeToStream, ReadOnlyMemory<byte> data, CancellationToken cancellationToken = default)

System.Text.Json (4)

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

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

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