AsTask

tests\Shared\AsyncTestHelpers.cs (2)

88return task.AsTask().TimeoutAfter(TimeSpan.FromMilliseconds(milliseconds), filePath, lineNumber); 93return task.AsTask().TimeoutAfter(timeout, filePath, lineNumber);

tests\Shared\AsyncTestHelpers.cs (2)

88return task.AsTask().TimeoutAfter(TimeSpan.FromMilliseconds(milliseconds), filePath, lineNumber); 93return task.AsTask().TimeoutAfter(timeout, filePath, lineNumber);

Orchestrator\OrchestratorHostService.cs (1)

57await disposable.DisposeAsync().AsTask().ConfigureAwait(false);

tests\Shared\AsyncTestHelpers.cs (2)

88return task.AsTask().TimeoutAfter(TimeSpan.FromMilliseconds(milliseconds), filePath, lineNumber); 93return task.AsTask().TimeoutAfter(timeout, filePath, lineNumber);

tests\Shared\AsyncTestHelpers.cs (2)

88return task.AsTask().TimeoutAfter(TimeSpan.FromMilliseconds(milliseconds), filePath, lineNumber); 93return task.AsTask().TimeoutAfter(timeout, filePath, lineNumber);

tests\Shared\AsyncTestHelpers.cs (2)

88return task.AsTask().TimeoutAfter(TimeSpan.FromMilliseconds(milliseconds), filePath, lineNumber); 93return task.AsTask().TimeoutAfter(timeout, filePath, lineNumber);

tests\Shared\AsyncTestHelpers.cs (2)

88return task.AsTask().TimeoutAfter(TimeSpan.FromMilliseconds(milliseconds), filePath, lineNumber); 93return task.AsTask().TimeoutAfter(timeout, filePath, lineNumber);

tests\Shared\AsyncTestHelpers.cs (2)

88return task.AsTask().TimeoutAfter(TimeSpan.FromMilliseconds(milliseconds), filePath, lineNumber); 93return task.AsTask().TimeoutAfter(timeout, filePath, lineNumber);

DistributedApplicationFactory.cs (2)

497public virtual void Dispose() => DisposeAsync().AsTask().GetAwaiter().GetResult(); 603await asyncDisposable.DisposeAsync().AsTask().WaitAsync(appFactory._disposingCts.Token).ConfigureAwait(false);

TestingBuilderTests.cs (2)

478await app.DisposeAsync().AsTask().WaitAsync(cts.Token); 540await app.DisposeAsync().AsTask().WaitAsync(cts.Token);

TestingFactoryCrashTests.cs (1)

35await factory.DisposeAsync().AsTask().WaitAsync(cts.Token);

Dashboard\DashboardResourceTests.cs (1)

509await app.DisposeAsync().AsTask().DefaultTimeout();

tests\Shared\AsyncTestHelpers.cs (2)

88return task.AsTask().TimeoutAfter(TimeSpan.FromMilliseconds(milliseconds), filePath, lineNumber); 93return task.AsTask().TimeoutAfter(timeout, filePath, lineNumber);

tests\Shared\AsyncTestHelpers.cs (2)

88return task.AsTask().TimeoutAfter(TimeSpan.FromMilliseconds(milliseconds), filePath, lineNumber); 93return task.AsTask().TimeoutAfter(timeout, filePath, lineNumber);

tests\Shared\AsyncTestHelpers.cs (2)

88return task.AsTask().TimeoutAfter(TimeSpan.FromMilliseconds(milliseconds), filePath, lineNumber); 93return task.AsTask().TimeoutAfter(timeout, filePath, lineNumber);

Http2\Http2ConnectionTests.cs (1)

61return c.Response.Body.WriteAsync(new byte[1]).AsTask();

Http2\Http2WebSocketTests.cs (2)

456var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => context.Response.Body.WriteAsync(new byte[1] { 0x00 }).AsTask()); 465ex = await Assert.ThrowsAsync<InvalidOperationException>(() => context.Response.Body.WriteAsync(new byte[1] { 0x00 }).AsTask());

KestrelMetricsTests.cs (1)

825shutdownTask = server.DisposeAsync().AsTask();

Http3\Http3RequestTests.cs (1)

667writeAsyncTask.SetResult(context.Response.Body.WriteAsync(TestData).AsTask());

NavigationManager.cs (2)

401await handlerTask.AsTask().WaitAsync(cancellationToken); 429locationChangingTasks.Add(handlerTask.AsTask());

RenderTree\Renderer.cs (2)

985var result = disposalTask.AsTask(); 1219asyncDisposables.Add(task.AsTask());

QuickGrid.razor.cs (1)

215_ = _jsModule?.InvokeVoidAsync("checkColumnOptionsPosition", _tableReference).AsTask();

JSComponents\JSComponentInterop.cs (2)

177() => jsObjectReference.InvokeVoidAsync(JSFunctionPropertyName).AsTask()); 185value => jsObjectReference.InvokeVoidAsync(JSFunctionPropertyName, value).AsTask());

TargetPickerUi.cs (1)

55await toStream.WriteAsync(bytesWithHeader, token).AsTask();

Services\WebViewScrollToLocationHash.cs (1)

38await _jsRuntime.InvokeVoidAsync("Blazor._internal.navigationManager.scrollToElement", elementId).AsTask();

HealthCheckResponseWriters.cs (3)

21HealthStatus.Degraded => httpContext.Response.Body.WriteAsync(DegradedBytes.AsMemory()).AsTask(), 22HealthStatus.Healthy => httpContext.Response.Body.WriteAsync(HealthyBytes.AsMemory()).AsTask(), 23HealthStatus.Unhealthy => httpContext.Response.Body.WriteAsync(UnhealthyBytes.AsMemory()).AsTask(),

Internal\WebHost.cs (1)

315DisposeAsync().AsTask().GetAwaiter().GetResult();

Features\RequestServicesFeature.cs (1)

88DisposeAsync().AsTask().GetAwaiter().GetResult();

HttpResponse.cs (1)

25return asyncDisposable.DisposeAsync().AsTask();

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

58return WriteCoreAsync(buffer.AsMemory(offset, count), cancellationToken).AsTask();

Internal\SendUtils.cs (1)

102return stream.WriteAsync(_buffer).AsTask();

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

58return WriteCoreAsync(buffer.AsMemory(offset, count), cancellationToken).AsTask();

Utf8ContentHttpResult.cs (1)

68return httpContext.Response.Body.WriteAsync(ResponseContent).AsTask();

PushStreamResultTests.cs (3)

15var result = new PushStreamHttpResult(body => body.WriteAsync(Encoding.UTF8.GetBytes("Hello World").AsMemory()).AsTask(), contentType: null); 37var callback = (Stream body) => body.WriteAsync(Encoding.UTF8.GetBytes("Hello World").AsMemory()).AsTask(); 55var callback = (Stream body) => body.WriteAsync(Encoding.UTF8.GetBytes("Hello World").AsMemory()).AsTask();

HttpLoggingMiddleware.cs (1)

312interceptors[i].OnResponseAsync(logContext).AsTask().GetAwaiter().GetResult();

src\Shared\TaskExtensions.cs (2)

46return task.AsTask().TimeoutAfter(TimeSpan.FromMilliseconds(milliseconds), filePath, lineNumber); 51return task.AsTask().TimeoutAfter(timeout, filePath, lineNumber);

Infrastructure\ResourceInvoker.cs (1)

82return ReleaseResourcesCore(scope).AsTask();

WebApplicationFactory.cs (1)

753.AsTask()

CachedResponseBodyTests.cs (1)

36var copyTask = RecyclableReadOnlySequenceSegment.CopyToAsync(body, pipe.Writer, cts.Token).AsTask().ContinueWith(t => pipe.Writer.CompleteAsync(t.Exception));

MemoryOutputCacheStoreTests.cs (2)

48_ = await Assert.ThrowsAsync<ArgumentNullException>("key", () => store.SetAsync(key, value, null, TimeSpan.FromMilliseconds(5), default).AsTask()); 58_ = await Assert.ThrowsAsync<ArgumentNullException>("value", () => store.SetAsync(key, value, null, TimeSpan.FromMilliseconds(5), default).AsTask());

ResponseCachingBenchmark.cs (1)

123public Task CompleteAsync() => Writer.CompleteAsync().AsTask();

Internal\Infrastructure\TransportManager.cs (1)

157tasks[i] = transportsToStop[i].DisposeAsync().AsTask();

Internal\WebTransport\WebTransportSession.cs (2)

82stream.Value.DisposeAsync().AsTask().GetAwaiter().GetResult(); 189stream.DisposeAsync().AsTask().GetAwaiter().GetResult();

Internal\QuicConnectionContext.cs (2)

60_closeTask ??= _connection.CloseAsync(errorCode: _context.Options.DefaultCloseErrorCode).AsTask(); 88_closeTask = _connection.CloseAsync(errorCode: resolvedErrorCode).AsTask();

QuicConnectionListenerTests.cs (3)

59await serverConnection.DisposeAsync().AsTask().DefaultTimeout(); 79await serverConnection1.DisposeAsync().AsTask().DefaultTimeout(); 104await serverConnection2.DisposeAsync().AsTask().DefaultTimeout();

QuicStreamContextTests.cs (1)

522var clientEx = await Assert.ThrowsAsync<QuicException>(() => clientStream.WriteAsync(data).AsTask()).DefaultTimeout();

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

58return WriteCoreAsync(buffer.AsMemory(offset, count), cancellationToken).AsTask();

HubConnectionTests.cs (3)

802await channelWriter.Writer.WriteAsync("1").AsTask().DefaultTimeout(); 804await channelWriter.Writer.WriteAsync("2").AsTask().DefaultTimeout(); 2346Assert.True(connection.DisposeAsync().AsTask().Wait(DefaultTimeout));

HubConnectionTests.cs (1)

448await channel.Writer.WriteAsync(number).AsTask().DefaultTimeout();

DefaultHubLifetimeManager.cs (3)

126tasks.Add(task.AsTask()); 171tasks.Add(task.AsTask()); 198return connection.WriteAsync(message, cancellationToken).AsTask();

Internal\DefaultHubDispatcher.cs (2)

293hubMethodInvocationMessage.InvocationId, $"Unknown hub method '{hubMethodInvocationMessage.Target}'")).AsTask(); 309}, (this, descriptor, connection, hubMethodInvocationMessage)).AsTask();

StreamTracker.cs (1)

134return _channel.Writer.WriteAsync((T?)o).AsTask();

src\Shared\TaskExtensions.cs (2)

46return task.AsTask().TimeoutAfter(TimeSpan.FromMilliseconds(milliseconds), filePath, lineNumber); 51return task.AsTask().TimeoutAfter(timeout, filePath, lineNumber);

RedisHubLifetimeManager.cs (5)

176return connection.WriteAsync(new InvocationMessage(methodName, args), cancellationToken).AsTask(); 467tasks.Add(connection.WriteAsync(invocation.Message).AsTask()); 579return connection.WriteAsync(invocation.Message).AsTask(); 600tasks.Add(userConnection.WriteAsync(invocation.Message).AsTask()); 631tasks.Add(groupConnection.WriteAsync(invocation.Message).AsTask());

ResponseFeature.cs (1)

150return Writer.CompleteAsync().AsTask();

TestClientTests.cs (5)

222await requestStream.WriteAsync(Encoding.UTF8.GetBytes("Hello world")).AsTask().DefaultTimeout(); 326await requestStream.WriteAsync(Encoding.UTF8.GetBytes("SENT")).AsTask().DefaultTimeout(); 386await requestStream.WriteAsync(Encoding.UTF8.GetBytes(new string('!', 1024 * 1024 * 50))).AsTask().DefaultTimeout(); 493await Assert.ThrowsAnyAsync<Exception>(() => requestStream.WriteAsync(buffer).AsTask()); 544() => requestStream.WriteAsync(Encoding.UTF8.GetBytes("Hello world")).AsTask(),

HttpResponseStreamWriterTest.cs (1)

827=> WriteAsync(buffer.AsMemory(offset, count), cancellationToken).AsTask();

Internal\Editor\FindUsages\FSharpFindUsagesContext.cs (4)

27return _context.OnDefinitionFoundAsync(definition.RoslynDefinitionItem, CancellationToken).AsTask(); 32return _context.OnReferencesFoundAsync(IAsyncEnumerableExtensions.SingletonAsync(reference.RoslynSourceReferenceItem), CancellationToken).AsTask(); 37return _context.ReportNoResultsAsync(message, CancellationToken).AsTask(); 47return _context.SetSearchTitleAsync(title, CancellationToken).AsTask();

MSBuild\MSBuildWorkspace.cs (1)

324_applyChangesBuildHostProcessManager!.DisposeAsync().AsTask().Wait();

Utilities\DotNetSdkMSBuildInstalled.cs (1)

51buildHostProcessManager?.DisposeAsync().AsTask().Wait();

Utilities\VisualStudioMSBuildInstalled.cs (1)

42buildHostProcessManager?.DisposeAsync().AsTask().Wait();

ServiceLookup\ServiceProviderEngineScope.cs (1)

111Task.Run(() => ((IAsyncDisposable)localService).DisposeAsync().AsTask()).GetAwaiter().GetResult();

Internal\Host.cs (1)

411public void Dispose() => DisposeAsync().AsTask().GetAwaiter().GetResult();

Infrastructure\DotNetDispatcher.cs (1)

123valueTaskResult.AsTask().ContinueWith(t => EndInvokeDotNetAfterTask(t, jsRuntime, invocationInfo), TaskScheduler.Current);

ProjectSystem\VisualStudioWorkspaceImpl.OpenFileTracker.cs (1)

379}).AsTask();

Workspace\SourceGeneratedFileManager.cs (1)

201_threadingContext.JoinableTaskFactory.Run(() => openFile.RefreshFileAsync(CancellationToken.None).AsTask());

System\IO\Compression\DeflateZLib\DeflateStream.cs (2)

813return WriteAsyncMemory(new ReadOnlyMemory<byte>(buffer, offset, count), cancellationToken).AsTask(); 1017return WriteAsyncCore(buffer.AsMemory(offset, count), cancellationToken).AsTask();

System\IO\Compression\ZipArchiveEntry.cs (1)

1514return WriteAsync(new ReadOnlyMemory<byte>(buffer, offset, count), cancellationToken).AsTask();

System\IO\Compression\ZipCustomStreams.cs (1)

562return WriteAsync(new ReadOnlyMemory<byte>(buffer, offset, count), cancellationToken).AsTask();

System\IO\Compression\enc\BrotliStream.Compress.cs (1)

133return WriteAsync(new ReadOnlyMemory<byte>(buffer, offset, count), cancellationToken).AsTask();

src\libraries\Common\src\System\IO\ReadOnlyMemoryStream.cs (1)

174return destination.WriteAsync(content, cancellationToken).AsTask();

src\libraries\Common\src\System\IO\ReadOnlyMemoryStream.cs (1)

174return destination.WriteAsync(content, cancellationToken).AsTask();

System\Net\Http\HttpBaseStream.cs (1)

72return WriteAsync(new ReadOnlyMemory<byte>(buffer, offset, count), cancellationToken).AsTask();

System\Net\Http\ReadOnlyMemoryContent.cs (2)

23stream.WriteAsync(_content).AsTask(); 26stream.WriteAsync(_content, cancellationToken).AsTask();

System\Net\Http\SocketsHttpHandler\ChunkedEncodingWriteStream.cs (1)

84return connection.WriteAsync(s_finalChunkBytes).AsTask();

System\Net\Http\SocketsHttpHandler\Http2Stream.cs (1)

1436new ValueTask(this, _waitSource.Version).AsTask().GetAwaiter().GetResult();

System\Net\Http\SocketsHttpHandler\Http3Connection.cs (2)

146_connectionClosedTask ??= _connection.CloseAsync((long)Http3ErrorCode.NoError).AsTask(); 397_connectionClosedTask = _connection.CloseAsync((long)connectionResetErrorCode).AsTask();

System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (3)

93_connection.LogExceptions(_stream.DisposeAsync().AsTask()); 119_connection.LogExceptions(_stream.DisposeAsync().AsTask()); 1547return stream.FlushSendBufferAsync(endStream: false, cancellationToken).AsTask();

System\Net\Http\SocketsHttpHandler\HttpContentWriteStream.cs (1)

30connection.FlushAsync(async: true).AsTask() :

System\Net\Http\SocketsHttpHandler\RawConnectionStream.cs (1)

205flushTask.AsTask() :

System\Net\DelegatedStream.cs (1)

203return WriteAsyncInternal(buffer.AsMemory(offset, count), cancellationToken).AsTask();

src\libraries\Common\src\System\Net\StreamBuffer.cs (1)

345new ValueTask(this, _waitSource.Version).AsTask().GetAwaiter().GetResult();

System\Net\Quic\QuicListener.cs (1)

300if (task.AsTask().Exception?.InnerException is Exception handshakeException)

System\Net\Quic\QuicStream.Stream.cs (3)

187WriteAsync(buffer.ToArray(), cts?.Token ?? default).AsTask().GetAwaiter().GetResult(); 204return WriteAsync(new ReadOnlyMemory<byte>(buffer, offset, count), cancellationToken).AsTask(); 222DisposeAsync().AsTask().GetAwaiter().GetResult();

System\Net\RequestStream.cs (1)

106return _internalStream.WriteAsync(buffer.AsMemory(offset, count), cancellationToken).AsTask();

System\Net\Security\SslStream.cs (2)

455return InnerStream.WriteAsync(new ReadOnlyMemory<byte>(token.Payload, 0, token.Size), default).AsTask(); 872return WriteAsyncInternal<AsyncReadWriteAdapter>(new ReadOnlyMemory<byte>(buffer, offset, count), cancellationToken).AsTask();

System\Net\Sockets\NetworkStream.cs (1)

638cancellationToken).AsTask();

System\Net\Sockets\Socket.cs (2)

2463TaskToAsyncResult.Begin(DisconnectAsync(reuseSocket).AsTask(), callback, state); 2567return TaskToAsyncResult.Begin(SendFileAsync(fileName, preBuffer, postBuffer, flags).AsTask(), callback, state);

System\Net\Sockets\Socket.Tasks.cs (3)

78public Task ConnectAsync(EndPoint remoteEP) => ConnectAsync(remoteEP, default).AsTask(); 152public Task ConnectAsync(IPAddress[] addresses, int port) => ConnectAsync(addresses, port, CancellationToken.None).AsTask(); 229public Task ConnectAsync(string host, int port) => ConnectAsync(host, port, default).AsTask();

System\Net\WebSockets\ManagedWebSocket.cs (2)

311return SendAsync(buffer, messageType, endOfMessage ? WebSocketMessageFlags.EndOfMessage : default, cancellationToken).AsTask(); 1868LogExceptions(t.AsTask());

src\libraries\System.Private.CoreLib\src\System\IO\BufferedStream.cs (1)

1001return WriteAsync(new ReadOnlyMemory<byte>(buffer, offset, count), cancellationToken).AsTask();

src\libraries\System.Private.CoreLib\src\System\IO\Strategies\BufferedFileStreamStrategy.cs (1)

586return WriteAsync(new ReadOnlyMemory<byte>(buffer, offset, count), cancellationToken).AsTask();

src\libraries\System.Private.CoreLib\src\System\IO\Strategies\OSFileStreamStrategy.cs (1)

255WriteAsync(new ReadOnlyMemory<byte>(buffer, offset, count), cancellationToken).AsTask();

src\libraries\System.Private.CoreLib\src\System\Text\TranscodingStream.cs (1)

540return WriteAsync(new ReadOnlyMemory<byte>(buffer, offset, count), cancellationToken).AsTask();

src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Task.cs (1)

7036waitTask = new ValueTask(waitTask.AsTask().WaitAsync(cancellationToken));

src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\ValueTask.cs (2)

32/// should be extracted using <see cref="AsTask"/>. Such operations might include caching a task instance to be awaited later, 183public ValueTask Preserve() => _obj == null ? this : new ValueTask(AsTask());

System\Security\Cryptography\CryptoStream.cs (3)

119FlushFinalBlockAsync(useAsync: false, default).AsTask().GetAwaiter().GetResult(); 459return WriteAsyncInternal(buffer.AsMemory(offset, count), cancellationToken).AsTask(); 499WriteAsyncCore(buffer.AsMemory(offset, count), default, useAsync: false).AsTask().GetAwaiter().GetResult();

System\ServiceModel\Channels\Connection.cs (2)

193return Connection.WriteAsync(new Memory<byte>(buffer, offset, count), Immediate, TimeoutHelper.FromMilliseconds(WriteTimeout)).AsTask(); 224.AsTask()

System\ServiceModel\Channels\ConnectionPool.cs (1)

336if (!valueTask.IsCompletedSuccessfully) closeTasks.Add(valueTask.AsTask());

Sdk\AssertHelper.cs (1)

735 Task.Run(valueTask.AsTask).GetAwaiter().GetResult();