FlushResult

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

ConcurrentPipeWriterTests.cs (1)

379pipeWriterFlushTcsArray[0].SetResult(new FlushResult(isCanceled: true, isCompleted: false));

HttpResponseStreamTests.cs (1)

114mockHttpResponseControl.Setup(m => m.WritePipeAsync(It.IsAny<ReadOnlyMemory<byte>>(), CancellationToken.None)).Returns(new ValueTask<FlushResult>(new FlushResult()));

Mocks\NullPipeWriter.cs (1)

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

Internal\QuicStreamContext.cs (2)

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

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

60_completedTCS.SetResult(new()); 254FlushResult finalResult = new();

HubConnectionContext.cs (2)

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

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

60_completedTCS.SetResult(new()); 254FlushResult finalResult = new();

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

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

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

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

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

Tcp\TcpConnection.cs (1)

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

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\Shared\ValueTaskExtensions\ValueTaskExtensions.cs (2)

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

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\Shared\ValueTaskExtensions\ValueTaskExtensions.cs (2)

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

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\Shared\ValueTaskExtensions\ValueTaskExtensions.cs (2)

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

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

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

Http2\Http2StreamTests.cs (3)

4300var result = await httpContext.Response.BodyWriter.WriteAsync(payload); 4333var cancelledResult = await httpContext.Response.BodyWriter.WriteAsync(payload); 4337var goodResult = await httpContext.Response.BodyWriter.WriteAsync(secondPayload);

Http3\Http3StreamTests.cs (3)

770var result = await context.Response.BodyWriter.WriteAsync(payload); 801var cancelledResult = await context.Response.BodyWriter.WriteAsync(payload); 805var goodResult = await context.Response.BodyWriter.WriteAsync(secondPayload);

Http3\WebTransport\WebTransportTestUtilities.cs (6)

120public ValueTask<FlushResult> FlushPipeAsync(CancellationToken cancellationToken) 123return new ValueTask<FlushResult>(); 142public ValueTask<FlushResult> ProduceContinueAsync() 145return new ValueTask<FlushResult>(); 154public ValueTask<FlushResult> WritePipeAsync(ReadOnlyMemory<byte> source, CancellationToken cancellationToken) 157return new ValueTask<FlushResult>();

ResponseTests.cs (3)

223var result = await context.Response.BodyWriter.WriteAsync(payload); 250var cancelledResult = await context.Response.BodyWriter.WriteAsync(payload); 254var goodResult = await context.Response.BodyWriter.WriteAsync(secondPayload);

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)

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

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

Http3\Http3RequestTests.cs (1)

1199var flushResult = await context.Response.BodyWriter.FlushAsync();

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\Shared\ValueTaskExtensions\ValueTaskExtensions.cs (2)

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

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

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

Internal\Transports\WebSocketsServerTransport.cs (1)

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

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\SignalR\common\Shared\PipeWriterStream.cs (2)

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

Internal\LongPollingTransport.cs (1)

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

Internal\ServerSentEventsTransport.cs (1)

146var flushResult = await _application.Output.WriteAsync(item.Data, default).ConfigureAwait(false);

Internal\WebSocketsTransport.cs (1)

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

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

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

HttpConnectionManagerTests.cs (3)

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

EndToEndBenchmarks.cs (1)

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

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

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

Core\IISHttpContext.IO.cs (1)

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

Core\OutputProducer.cs (1)

105private async Task FlushNowAsyncAwaited(ValueTask<FlushResult> awaitable, CancellationToken cancellationToken)

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

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

Internal\Http\Http1OutputProducer.cs (17)

Internal\Http\HttpProtocol.cs (9)

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)

1874var result = await writer.FlushAsync();

Internal\Http2\Http2FrameWriter.cs (17)

Internal\Http2\Http2MessageBody.cs (1)

49ValueTask<FlushResult> continueTask = TryProduceContinueAsync();

Internal\Http2\Http2OutputProducer.cs (18)

Internal\Http3\Http3Connection.cs (1)

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

Internal\Http3\Http3ControlStream.cs (1)

148internal 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)

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\Shared\ValueTaskExtensions\ValueTaskExtensions.cs (2)

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

ConcurrentPipeWriterTests.cs (24)

Http1\Http1ConnectionTests.cs (5)

720var successResult = await writer.WriteAsync(payload); 724var failResult = await _http1Connection.FlushPipeAsync(new CancellationToken()); 734var successResult = await writer.WriteAsync(payload); 739var canceledResult = await _http1Connection.FlushPipeAsync(new CancellationToken()); 743var goodResult = await _http1Connection.FlushPipeAsync(new CancellationToken());

Http1\Http1OutputProducerTests.cs (5)

72var successResult = await socketOutput.FlushAsync(); 79var completedResult = await socketOutput.FlushAsync(); 100var successResult = await socketOutput.FlushAsync(); 106var cancelResult = await socketOutput.WriteDataToPipeAsync(new byte[] { 1, 2, 3, 4 }, default); 110var goodResult = await socketOutput.WriteDataToPipeAsync(new byte[] { 1, 2, 3, 4 }, default);

HttpResponseStreamTests.cs (1)

114mockHttpResponseControl.Setup(m => m.WritePipeAsync(It.IsAny<ReadOnlyMemory<byte>>(), CancellationToken.None)).Returns(new ValueTask<FlushResult>(new FlushResult()));

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

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

InMemoryTransportBenchmark.cs (1)

186public ValueTask<FlushResult> SendRequestAsync(byte[] request)

Mocks\NullPipeWriter.cs (2)

28public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default) 30return new ValueTask<FlushResult>(new FlushResult(false, true));

ResponseHeadersWritingBenchmark.cs (1)

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

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)

Internal\NamedPipeConnection.cs (1)

108var result = await flushTask;

Internal\QuicStreamContext.cs (3)

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

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)

Internal\SocketConnection.cs (1)

182var result = await flushTask;

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

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

HubConnection.cs (2)

1499var sendHandshakeResult = await startingConnectionState.Connection.Transport.Output.FlushAsync(CancellationToken.None).ConfigureAwait(false); 2301public ValueTask<FlushResult> WriteAsync(HubMessage message, CancellationToken cancellationToken)

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\SignalR\common\Shared\MessageBuffer.cs (9)

21private static readonly TaskCompletionSource<FlushResult> _completedTCS = new TaskCompletionSource<FlushResult>(); 50private TaskCompletionSource<FlushResult> _resend = _completedTCS; 122public ValueTask<FlushResult> WriteAsync(SerializedHubMessage hubMessage, CancellationToken cancellationToken) 128public ValueTask<FlushResult> WriteAsync(HubMessage hubMessage, CancellationToken cancellationToken) 133private async ValueTask<FlushResult> WriteAsyncCore(Type hubMessageType, ReadOnlyMemory<byte> messageBytes, CancellationToken cancellationToken) 157ValueTask<FlushResult> writeTask; 251var tcs = new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously); 254FlushResult finalResult = new();

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

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

HubConnectionContext.cs (5)

268private ValueTask<FlushResult> WriteCore(HubMessage message, CancellationToken cancellationToken) 292return new ValueTask<FlushResult>(new FlushResult(isCanceled: false, isCompleted: true)); 296private ValueTask<FlushResult> WriteCore(SerializedHubMessage message, CancellationToken cancellationToken) 320return new ValueTask<FlushResult>(new FlushResult(isCanceled: false, isCompleted: true)); 324private async Task CompleteWriteAsync(ValueTask<FlushResult> task)

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

21private static readonly TaskCompletionSource<FlushResult> _completedTCS = new TaskCompletionSource<FlushResult>(); 50private TaskCompletionSource<FlushResult> _resend = _completedTCS; 122public ValueTask<FlushResult> WriteAsync(SerializedHubMessage hubMessage, CancellationToken cancellationToken) 128public ValueTask<FlushResult> WriteAsync(HubMessage hubMessage, CancellationToken cancellationToken) 133private async ValueTask<FlushResult> WriteAsyncCore(Type hubMessageType, ReadOnlyMemory<byte> messageBytes, CancellationToken cancellationToken) 157ValueTask<FlushResult> writeTask; 251var tcs = new TaskCompletionSource<FlushResult>(TaskCreationOptions.RunContinuationsAsynchronously); 254FlushResult finalResult = new();

Shared\TestPipeWriter.cs (3)

39public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = new CancellationToken()) 46return new ValueTask<FlushResult>(ForceAsyncResult()); 49public async Task<FlushResult> ForceAsyncResult()

ResponseBodyPipeWriter.cs (1)

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

Logging\Internal\HttpResponseBodyReader.cs (1)

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

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

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

Startup.cs (1)

58public static Task GetAsTask(this in ValueTask<FlushResult> valueTask)

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)

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

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)

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)

339FlushResult 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)

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

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

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

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