AsTask

289 references to AsTask

Aspire.Dashboard.Components.Tests (3)

Shared\TestDashboardClient.cs (1)

48return _resourceCommandsChannel.Reader.ReadAsync(cancellationToken).AsTask();

tests\Shared\AsyncTestHelpers.cs (2)

118return task.AsTask().TimeoutAfter(TimeSpan.FromMilliseconds(milliseconds), filePath, lineNumber); 123return task.AsTask().TimeoutAfter(timeout, filePath, lineNumber);

Aspire.Dashboard.Tests (2)

tests\Shared\AsyncTestHelpers.cs (2)

118return task.AsTask().TimeoutAfter(TimeSpan.FromMilliseconds(milliseconds), filePath, lineNumber); 123return task.AsTask().TimeoutAfter(timeout, filePath, lineNumber);

Aspire.Hosting.Kafka.Tests (2)

tests\Shared\AsyncTestHelpers.cs (2)

118return task.AsTask().TimeoutAfter(TimeSpan.FromMilliseconds(milliseconds), filePath, lineNumber); 123return task.AsTask().TimeoutAfter(timeout, filePath, lineNumber);

Aspire.Hosting.MySql.Tests (2)

tests\Shared\AsyncTestHelpers.cs (2)

118return task.AsTask().TimeoutAfter(TimeSpan.FromMilliseconds(milliseconds), filePath, lineNumber); 123return task.AsTask().TimeoutAfter(timeout, filePath, lineNumber);

Aspire.Hosting.NodeJs.Tests (2)

tests\Shared\AsyncTestHelpers.cs (2)

118return task.AsTask().TimeoutAfter(TimeSpan.FromMilliseconds(milliseconds), filePath, lineNumber); 123return task.AsTask().TimeoutAfter(timeout, filePath, lineNumber);

Aspire.Hosting.PostgreSQL.Tests (2)

tests\Shared\AsyncTestHelpers.cs (2)

118return task.AsTask().TimeoutAfter(TimeSpan.FromMilliseconds(milliseconds), filePath, lineNumber); 123return task.AsTask().TimeoutAfter(timeout, filePath, lineNumber);

Aspire.Hosting.RabbitMQ.Tests (2)

tests\Shared\AsyncTestHelpers.cs (2)

118return task.AsTask().TimeoutAfter(TimeSpan.FromMilliseconds(milliseconds), filePath, lineNumber); 123return task.AsTask().TimeoutAfter(timeout, filePath, lineNumber);

Aspire.Hosting.Tests (5)

Dcp\DcpExecutorTests.cs (3)

595var moveNextTask = watchLogsEnumerator.MoveNextAsync().AsTask(); 615moveNextTask = watchLogsEnumerator.MoveNextAsync().AsTask(); 632moveNextTask = watchLogsEnumerator.MoveNextAsync().AsTask();

tests\Shared\AsyncTestHelpers.cs (2)

118return task.AsTask().TimeoutAfter(TimeSpan.FromMilliseconds(milliseconds), filePath, lineNumber); 123return task.AsTask().TimeoutAfter(timeout, filePath, lineNumber);

Aspire.Hosting.Valkey.Tests (2)

tests\Shared\AsyncTestHelpers.cs (2)

118return task.AsTask().TimeoutAfter(TimeSpan.FromMilliseconds(milliseconds), filePath, lineNumber); 123return task.AsTask().TimeoutAfter(timeout, filePath, lineNumber);

Aspire.Playground.Tests (2)

tests\Shared\AsyncTestHelpers.cs (2)

118return task.AsTask().TimeoutAfter(TimeSpan.FromMilliseconds(milliseconds), filePath, lineNumber); 123return task.AsTask().TimeoutAfter(timeout, filePath, lineNumber);

CustomAuthorizationFailureResponse (1)

Authorization\SampleAuthorizationMiddlewareResultHandler.cs (1)

58httpContext.Response.OnStarting(() => httpContext.Response.BodyWriter.WriteAsync(Encoding.UTF8.GetBytes(message)).AsTask());

http2cat (5)

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

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

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

78vt.AsTask().GetAwaiter().GetResult(); 83return ReadAsyncInternal(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

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

24return valueTask.AsTask(); 40return new ValueTask(valueTask.AsTask());

IIS.FunctionalTests (5)

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

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

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

78vt.AsTask().GetAwaiter().GetResult(); 83return ReadAsyncInternal(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

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

24return valueTask.AsTask(); 40return new ValueTask(valueTask.AsTask());

IIS.LongTests (5)

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

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

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

78vt.AsTask().GetAwaiter().GetResult(); 83return ReadAsyncInternal(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

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

24return valueTask.AsTask(); 40return new ValueTask(valueTask.AsTask());

IIS.NewHandler.FunctionalTests (5)

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

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

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

78vt.AsTask().GetAwaiter().GetResult(); 83return ReadAsyncInternal(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

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

24return valueTask.AsTask(); 40return new ValueTask(valueTask.AsTask());

IIS.NewShim.FunctionalTests (5)

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

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

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

78vt.AsTask().GetAwaiter().GetResult(); 83return ReadAsyncInternal(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

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

24return valueTask.AsTask(); 40return new ValueTask(valueTask.AsTask());

IIS.ShadowCopy.Tests (4)

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

78vt.AsTask().GetAwaiter().GetResult(); 83return ReadAsyncInternal(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

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

24return valueTask.AsTask(); 40return new ValueTask(valueTask.AsTask());

IISExpress.FunctionalTests (5)

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

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

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

78vt.AsTask().GetAwaiter().GetResult(); 83return ReadAsyncInternal(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

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

24return valueTask.AsTask(); 40return new ValueTask(valueTask.AsTask());

InMemory.FunctionalTests (10)

Http2\Http2TestBase.cs (1)

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

Http2\Http2WebSocketTests.cs (2)

458ex = await Assert.ThrowsAsync<InvalidOperationException>(() => context.Response.BodyWriter.WriteAsync(new byte[1] { 0x00 }).AsTask()); 467ex = await Assert.ThrowsAsync<InvalidOperationException>(() => context.Response.BodyWriter.WriteAsync(new byte[1] { 0x00 }).AsTask());

RequestTests.cs (1)

970var readResult = await httpContext.Request.BodyReader.ReadAsync().AsTask().DefaultTimeout();

ResponseTests.cs (4)

161var writeTask = context.Response.BodyWriter.WriteAsync(new Memory<byte>(data, 0, data.Length), cts.Token).AsTask().DefaultTimeout(); 168writeTask = context.Response.BodyWriter.WriteAsync(new Memory<byte>(data, 0, data.Length), cts.Token).AsTask().DefaultTimeout(); 2084return httpContext.Response.BodyWriter.WriteAsync(new Memory<byte>(response, 0, response.Length)).AsTask(); 3711return context.Response.BodyWriter.WriteAsync(new Memory<byte>(Encoding.ASCII.GetBytes("Hello!"), 0, 6)).AsTask();

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

520return task.AsTask().DefaultTimeout();

UpgradeTests.cs (1)

34await Assert.ThrowsAsync<InvalidOperationException>(() => context.Response.BodyWriter.WriteAsync(new byte[1]).AsTask());

Interop.FunctionalTests (3)

Http3\Http3RequestTests.cs (3)

477readAsyncTask.SetResult(body.ReadAsync(new byte[1024]).AsTask()); 549readAsyncTask.SetResult(context.Request.Body.ReadAsync(new byte[1024]).AsTask()); 999readAsyncTask.SetResult(requestBody.ReadAsync(data).AsTask());

Microsoft.AspNetCore.Components.Web (1)

Forms\InputFile\BrowserFileStream.cs (1)

68=> ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

Microsoft.AspNetCore.Grpc.JsonTranscoding (2)

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

24return valueTask.AsTask(); 40return new ValueTask(valueTask.AsTask());

Microsoft.AspNetCore.Http (3)

Internal\ReferenceReadStream.cs (1)

102=> ReadAsync(buffer.AsMemory(offset, count), cancellationToken).AsTask();

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

24return valueTask.AsTask(); 40return new ValueTask(valueTask.AsTask());

Microsoft.AspNetCore.Http.Abstractions (2)

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

24return valueTask.AsTask(); 40return new ValueTask(valueTask.AsTask());

Microsoft.AspNetCore.Http.Connections (2)

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

24return valueTask.AsTask(); 40return new ValueTask(valueTask.AsTask());

Microsoft.AspNetCore.Http.Connections.Tests (3)

HttpConnectionDispatcherTests.cs (3)

1863await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Unblock")).AsTask().DefaultTimeout(); 1915await connection.Transport.Output.WriteAsync(Encoding.UTF8.GetBytes("Unblock")).AsTask().DefaultTimeout(); 3821var result = connection.Transport.Input.ReadAsync().AsTask().Result;

Microsoft.AspNetCore.Identity.EntityFrameworkCore (5)

UserOnlyStore.cs (2)

222return UsersSet.FindAsync(new object?[] { id }, cancellationToken).AsTask(); 490=> UserTokens.FindAsync(new object[] { user.Id, loginProvider, name }, cancellationToken).AsTask();

UserStore.cs (3)

224return UsersSet.FindAsync(new object?[] { id }, cancellationToken).AsTask(); 271return UserRoles.FindAsync(new object[] { userId, roleId }, cancellationToken).AsTask(); 633=> UserTokens.FindAsync(new object[] { user.Id, loginProvider, name }, cancellationToken).AsTask();

Microsoft.AspNetCore.InternalTesting (2)

src\Shared\TaskExtensions.cs (2)

66return task.AsTask().TimeoutAfter(TimeSpan.FromMilliseconds(milliseconds), filePath, lineNumber); 71return task.AsTask().TimeoutAfter(timeout, filePath, lineNumber);

Microsoft.AspNetCore.Mvc.Core (3)

Formatters\TextOutputFormatter.cs (1)

139}).AsTask();

Infrastructure\ObjectResultExecutor.cs (1)

110}).AsTask();

ModelBinding\ParameterBinder.cs (1)

71=> BindModelAsync(actionContext, modelBinder, valueProvider, parameter, metadata, value, container: null).AsTask();

Microsoft.AspNetCore.Mvc.Core.Test (1)

Infrastructure\ActionMethodExecutorTest.cs (1)

434var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => Execute(actionMethodExecutor, filterContext, withFilter).AsTask());

Microsoft.AspNetCore.Mvc.FunctionalTests (1)

src\Shared\SizeLimitedStream.cs (1)

74return ReadAsync(buffer.AsMemory(offset, count), cancellationToken).AsTask();

Microsoft.AspNetCore.OutputCaching.Microbenchmarks (1)

EndToEndBenchmarks.cs (1)

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

Microsoft.AspNetCore.Owin (1)

OwinFeatureCollection.cs (1)

439return _responseBodyWrapper.FlushAsync().AsTask();

Microsoft.AspNetCore.RequestDecompression (1)

src\Shared\SizeLimitedStream.cs (1)

74return ReadAsync(buffer.AsMemory(offset, count), cancellationToken).AsTask();

Microsoft.AspNetCore.Routing.FunctionalTests (1)

src\Shared\SizeLimitedStream.cs (1)

74return ReadAsync(buffer.AsMemory(offset, count), cancellationToken).AsTask();

Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (5)

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

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

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

78vt.AsTask().GetAwaiter().GetResult(); 83return ReadAsyncInternal(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

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

24return valueTask.AsTask(); 40return new ValueTask(valueTask.AsTask());

Microsoft.AspNetCore.Server.IIS (5)

Core\HttpRequestStream.cs (1)

48return ReadAsyncInternal(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

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

78vt.AsTask().GetAwaiter().GetResult(); 83return ReadAsyncInternal(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

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

24return valueTask.AsTask(); 40return new ValueTask(valueTask.AsTask());

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

Internal\Http\HttpRequestStream.cs (1)

49return ReadAsyncWrapper(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

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

78vt.AsTask().GetAwaiter().GetResult(); 83return ReadAsyncInternal(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

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

24return valueTask.AsTask(); 40return new ValueTask(valueTask.AsTask());

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

HttpRequestPipeReaderTests.cs (2)

30await Assert.ThrowsAsync<TaskCanceledException>(() => pipeReader.ReadAsync().AsTask()); 41var exception = await Assert.ThrowsAsync<Exception>(() => pipeReader.ReadAsync().AsTask());

MessageBodyTests.cs (6)

1223var ex2 = await Assert.ThrowsAsync<BadHttpRequestException>(() => reader.ReadAsync().AsTask()); 1224var ex3 = await Assert.ThrowsAsync<BadHttpRequestException>(() => reader.ReadAsync().AsTask()); 1256var ex2 = await Assert.ThrowsAsync<BadHttpRequestException>(() => reader.ReadAsync().AsTask()); 1257var ex3 = await Assert.ThrowsAsync<BadHttpRequestException>(() => reader.ReadAsync().AsTask()); 1283var ex2 = await Assert.ThrowsAsync<BadHttpRequestException>(() => reader.ReadAsync().AsTask()); 1284var ex3 = await Assert.ThrowsAsync<BadHttpRequestException>(() => reader.ReadAsync().AsTask());

Microsoft.AspNetCore.Server.Kestrel.Transport.Quic.Tests (12)

QuicConnectionContextTests.cs (3)

69() => clientConnection.OpenOutboundStreamAsync(QuicStreamType.Unidirectional).AsTask(), 138var ex = await Assert.ThrowsAsync<ConnectionResetException>(() => acceptStreamTask.AsTask()).DefaultTimeout(); 487var clientEx = await Assert.ThrowsAsync<QuicException>(() => clientStream.ReadAsync(buffer).AsTask()).DefaultTimeout();

QuicConnectionListenerTests.cs (5)

184await Assert.ThrowsAsync<AuthenticationException>(() => QuicConnection.ConnectAsync(options).AsTask()); 204Assert.Null(await acceptTask.AsTask().DefaultTimeout()); 222Assert.Null(await acceptTask.AsTask().DefaultTimeout()); 257var ex = await Assert.ThrowsAsync<AuthenticationException>(() => QuicConnection.ConnectAsync(options).AsTask()).DefaultTimeout(); 404await Assert.ThrowsAsync<AuthenticationException>(() => clientConnectionTask.AsTask()).DefaultTimeout();

QuicStreamContextTests.cs (1)

467var ex = await Assert.ThrowsAsync<QuicException>(() => clientStream.ReadAsync(new byte[1024]).AsTask()).DefaultTimeout();

QuicTransportFactoryTests.cs (3)

32var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => quicTransportFactory.BindAsync(new IPEndPoint(0, 0), features: null, cancellationToken: CancellationToken.None).AsTask()).DefaultTimeout(); 49var ex = await Assert.ThrowsAsync<InvalidOperationException>(() => quicTransportFactory.BindAsync(new IPEndPoint(0, 0), features: features, cancellationToken: CancellationToken.None).AsTask()).DefaultTimeout(); 72await quicTransportFactory.BindAsync(new IPEndPoint(0, 0), features: features, cancellationToken: CancellationToken.None).AsTask().DefaultTimeout();

Microsoft.AspNetCore.Shared.Tests (4)

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

78vt.AsTask().GetAwaiter().GetResult(); 83return ReadAsyncInternal(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

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

24return valueTask.AsTask(); 40return new ValueTask(valueTask.AsTask());

Microsoft.AspNetCore.SignalR.Client.Core (2)

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

24return valueTask.AsTask(); 40return new ValueTask(valueTask.AsTask());

Microsoft.AspNetCore.SignalR.Client.FunctionalTests (7)

HubConnectionTests.cs (7)

803Assert.Equal("1", await channel.ReadAsync().AsTask().DefaultTimeout()); 805Assert.Equal("2", await channel.ReadAsync().AsTask().DefaultTimeout()); 850Assert.Equal("A", await channel.ReadAsync().AsTask().DefaultTimeout()); 851Assert.Equal("B", await channel.ReadAsync().AsTask().DefaultTimeout()); 852Assert.Equal("C", await channel.ReadAsync().AsTask().DefaultTimeout()); 853Assert.Equal("D", await channel.ReadAsync().AsTask().DefaultTimeout()); 982await channel.WaitToReadAsync().AsTask().DefaultTimeout();

Microsoft.AspNetCore.SignalR.Client.Tests (2)

TestConnection.cs (2)

109return Application.Output.WriteAsync(bytes).AsTask(); 119return Application.Output.WriteAsync(bytes).AsTask();

Microsoft.AspNetCore.SignalR.Specification.Tests (2)

src\Shared\TaskExtensions.cs (2)

66return task.AsTask().TimeoutAfter(TimeSpan.FromMilliseconds(milliseconds), filePath, lineNumber); 71return task.AsTask().TimeoutAfter(timeout, filePath, lineNumber);

Microsoft.AspNetCore.SignalR.Tests (1)

HubConnectionHandlerTestUtils\Hubs.cs (1)

288return source.WaitToReadAsync().AsTask();

Microsoft.AspNetCore.SignalR.Tests.Utils (1)

ChannelExtensions.cs (1)

59var readTask = reader.WaitToReadAsync(cancellationToken).AsTask();

Microsoft.AspNetCore.TestHost (1)

ResponseBodyReaderStream.cs (1)

74return ReadAsync(buffer.AsMemory(offset, count), cancellationToken).AsTask();

Microsoft.AspNetCore.TestHost.Tests (7)

TestClientTests.cs (7)

218var length = await responseContent.ReadAsync(buffer).AsTask().DefaultTimeout(); 227length = await responseContent.ReadAsync(buffer).AsTask().DefaultTimeout(); 235length = await responseContent.ReadAsync(buffer).AsTask().DefaultTimeout(); 378var length = await responseContent.ReadAsync(buffer).AsTask().DefaultTimeout(); 398length = await responseContent.ReadAsync(buffer).AsTask().DefaultTimeout(); 444var length = await responseContent.ReadAsync(buffer).AsTask().DefaultTimeout(); 489var length = await responseContent.ReadAsync(buffer).AsTask().DefaultTimeout();

Microsoft.AspNetCore.WebUtilities (5)

BufferedReadStream.cs (1)

222return ReadAsync(buffer.AsMemory(offset, count), cancellationToken).AsTask();

FileBufferingReadStream.cs (1)

329return ReadAsync(buffer.AsMemory(offset, count), cancellationToken).AsTask();

HttpRequestStreamReader.cs (1)

225return ReadAsync(memory).AsTask();

MultipartReaderStream.cs (1)

244=> ReadAsync(buffer.AsMemory(offset, count), cancellationToken).AsTask();

MultipartSectionStreamExtensions.cs (1)

20=> section.ReadAsStringAsync(CancellationToken.None).AsTask();

Microsoft.Build (4)

BackEnd\Client\MSBuildClientPacketPump.cs (2)

210Task<int> readTask = CommunicationsUtilities.ReadAsync(localStream, headerByte, headerByte.Length).AsTask(); 309readTask = CommunicationsUtilities.ReadAsync(localStream, headerByte, headerByte.Length).AsTask();

NodeEndpointOutOfProcBase.cs (2)

527Task<int> readTask = CommunicationsUtilities.ReadAsync(localReadPipe, headerByte, headerByte.Length).AsTask(); 619readTask = CommunicationsUtilities.ReadAsync(localReadPipe, headerByte, headerByte.Length).AsTask();

Microsoft.CodeAnalysis.CodeStyle (2)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\SpecializedTasks.cs (2)

81return new ValueTask<T[]>(Task.WhenAll(taskArray.Select(task => task.AsTask()))); 173return new ValueTask<TResult>(intermediateResult.AsTask().ContinueWith(

Microsoft.CodeAnalysis.EditorFeatures.Test.Utilities (1)

Workspaces\EditorTestHostDocument.cs (1)

170var document = threadingContext.JoinableTaskFactory.Run(() => workspace.CurrentSolution.GetSourceGeneratedDocumentAsync(testDocument.Id, CancellationToken.None).AsTask());

Microsoft.CodeAnalysis.Remote.ServiceHub (3)

Host\AssetProvider.cs (3)

108AssetPathKind.SolutionSourceGeneratorExecutionVersionMap, compilationStateChecksums.SourceGeneratorExecutionVersionMap, cancellationToken).AsTask()); 110AssetPathKind.SolutionAttributes, solutionStateChecksum.Attributes, cancellationToken).AsTask()); 114AssetPathKind.SolutionFallbackAnalyzerOptions, solutionStateChecksum.FallbackAnalyzerOptions, cancellationToken).AsTask());

Microsoft.CodeAnalysis.Workspaces (12)

ExternalAccess\Pythia\Api\PythiaDocumentExtensions.cs (1)

14=> DocumentExtensions.ReuseExistingSpeculativeModelAsync(document, node, cancellationToken).AsTask();

FindSymbols\SymbolFinder.cs (1)

140=> SymbolFinderInternal.FindSourceDefinitionAsync(symbol, solution, cancellationToken).AsTask();

Remote\IRemoteKeepAliveService.cs (2)

40_cancellationTokenSource.Token).AsTask(); 64cancellationToken).AsTask();

Rename\ConflictEngine\ConflictResolver.cs (1)

373var location = GetSymbolLocationAsync(solution, symbol, cancellationToken).AsTask().WaitAndGetResult_CanCallOnBackground(cancellationToken);

Shared\TestHooks\AsynchronousOperationListenerProvider.cs (1)

141CancellationToken.None).AsTask());

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\SpecializedTasks.cs (2)

81return new ValueTask<T[]>(Task.WhenAll(taskArray.Select(task => task.AsTask()))); 173return new ValueTask<TResult>(intermediateResult.AsTask().ContinueWith(

Workspace\Solution\Document.cs (1)

194return DocumentState.GetSyntaxTreeAsync(cancellationToken).AsTask().AsNullable();

Workspace\Solution\ProjectState_Checksum.cs (1)

30cancellationToken).AsTask();

Workspace\Solution\TextDocument.cs (1)

76=> GetValueTextAsync(cancellationToken).AsTask();

Workspace\Solution\TextDocumentState_Checksum.cs (1)

30cancellationToken).AsTask();

Microsoft.CodeAnalysis.Workspaces.UnitTests (3)

UtilityTest\SpecializedTasksTests.cs (3)

430var exception = await Assert.ThrowsAsync<InvalidOperationException>(() => task.AsTask()); 513var exception = await Assert.ThrowsAsync<TaskCanceledException>(() => task.AsTask()); 553var exception = await Assert.ThrowsAsync<InvalidOperationException>(() => task.AsTask());

Microsoft.DotNet.Internal.SymbolHelper (1)

SymbolUploadHelper.cs (1)

517return vt.AsTask();

Microsoft.Extensions.AI.Abstractions.Tests (2)

SpeechToText\SpeechToTextClientExtensionsTests.cs (2)

43var ex1 = await Assert.ThrowsAsync<ArgumentNullException>(() => SpeechToTextClientExtensions.GetStreamingTextAsync(client!, content).GetAsyncEnumerator().MoveNextAsync().AsTask()); 48var ex2 = await Assert.ThrowsAsync<ArgumentNullException>(() => SpeechToTextClientExtensions.GetStreamingTextAsync(testClient, nullContent!).GetAsyncEnumerator().MoveNextAsync().AsTask());

Microsoft.Extensions.AI.AzureAIInference.Tests (2)

AzureAIInferenceChatClientTests.cs (2)

43await Assert.ThrowsAsync<InvalidOperationException>(() => chatClient.GetStreamingResponseAsync("hello").GetAsyncEnumerator().MoveNextAsync().AsTask()); 46await Assert.ThrowsAsync<InvalidOperationException>(() => chatClient.GetStreamingResponseAsync("hello", new ChatOptions { ModelId = null }).GetAsyncEnumerator().MoveNextAsync().AsTask());

Microsoft.Extensions.AI.Evaluation (1)

Utilities\TaskExtensions.cs (1)

96StreamResultsAsync(concurrentTasks.Select(t => t.AsTask()), preserveOrder, cancellationToken);

Microsoft.Extensions.AI.OpenAI.Tests (1)

OpenAISpeechToTextClientTests.cs (1)

135.AsTask());

Microsoft.Extensions.AI.Tests (11)

Functions\AIFunctionFactoryTest.cs (11)

72Exception e = await Assert.ThrowsAsync<ArgumentException>(() => f.InvokeAsync().AsTask()); 130await Assert.ThrowsAsync<NotImplementedException>(() => func.InvokeAsync().AsTask()); 267await Assert.ThrowsAsync<ArgumentNullException>("arguments.Services", () => func.InvokeAsync(arguments).AsTask()); 316await Assert.ThrowsAsync<ArgumentException>("arguments", () => func.InvokeAsync(new()).AsTask()); 317await Assert.ThrowsAsync<ArgumentException>("arguments", () => func.InvokeAsync(new() { Services = sp }).AsTask()); 340await Assert.ThrowsAsync<ArgumentNullException>("arguments.Services", () => func.InvokeAsync(new()).AsTask()); 341await Assert.ThrowsAsync<ArgumentException>("arguments", () => func.InvokeAsync(new() { Services = new ServiceCollection().BuildServiceProvider() }).AsTask()); 493Exception e = await Assert.ThrowsAsync<ArgumentNullException>("arguments.Services", () => f.InvokeAsync(new() { ["myInteger"] = 1 }).AsTask()); 514Exception e = await Assert.ThrowsAsync<ArgumentNullException>("arguments.Services", () => f.InvokeAsync(new() { ["myInteger"] = 1 }).AsTask()); 573Exception e = await Assert.ThrowsAsync<ArgumentException>(() => f.InvokeAsync(new() { ["myInteger"] = 1 }).AsTask()); 580}).AsTask());

Microsoft.Extensions.Caching.Hybrid.Tests (6)

StampedeTests.cs (6)

110}, cancellationToken: token).AsTask(); 146}, cancellationToken: token).AsTask(); 206}, cancellationToken: cancels[i].Token).AsTask(); 284}, cancellationToken: cancels[i].Token).AsTask(); 345}, cancellationToken: token).AsTask(); 352}, cancellationToken: token).AsTask();

Microsoft.JSInterop (1)

Infrastructure\DotNetDispatcher.cs (1)

379private static Task CreateValueTaskConverter<[DynamicallyAccessedMembers(LinkerFlags.JsonSerialized)] T>(object result) => ((ValueTask<T>)result).AsTask();

Microsoft.JSInterop.Tests (1)

JSRuntimeTest.cs (1)

201var exception = Assert.IsType<AggregateException>(task.AsTask().Exception);

Microsoft.ML.Data (1)

Transforms\RowShufflingTransformer.cs (1)

644readTask.AsTask().GetAwaiter().GetResult();

Microsoft.VisualStudio.LanguageServices (1)

ProjectSystem\VisualStudioWorkspaceImpl.cs (1)

304var document = _threadingContext.JoinableTaskFactory.Run(() => CurrentSolution.GetDocumentAsync(documentId, includeSourceGenerated: true).AsTask());

MSBuild (2)

NodeEndpointOutOfProcBase.cs (2)

PlaintextApp (1)

Startup.cs (1)

68return valueTask.AsTask();

SignalRSamples (1)

ConnectionHandlers\MessagesConnectionHandler.cs (1)

68tasks.Add(c.Transport.Output.WriteAsync(payload).AsTask());

System.Formats.Tar (1)

System\Formats\Tar\SubReadStream.cs (1)

141return ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

System.IO.Compression (3)

System\IO\Compression\DeflateManaged\DeflateManagedStream.cs (1)

257return ReadAsyncInternal(buffer.AsMemory(offset, count), cancellationToken).AsTask();

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

406return ReadAsyncMemory(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

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

338return ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

System.IO.Compression.Brotli (1)

System\IO\Compression\dec\BrotliStream.Decompress.cs (1)

122return ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

System.IO.Pipelines (2)

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

67ReadResult result = vt.IsCompletedSuccessfully ? vt.Result : vt.AsTask().GetAwaiter().GetResult(); 90return ReadAsyncInternal(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

System.IO.Pipes (1)

System\IO\Pipes\PipeStream.Unix.cs (1)

79return ReadAsyncCore(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

System.Net.Http (11)

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

54return ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

System\Net\Http\MultipartContent.cs (3)

241CreateContentReadStreamAsyncCore(async: true, CancellationToken.None).AsTask(); 246GetType() == typeof(MultipartContent) ? CreateContentReadStreamAsyncCore(async: true, cancellationToken).AsTask() : 523return ReadAsyncPrivate(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

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

162CreateContentReadStreamAsyncCore(async: true, cancellationToken).AsTask();

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

1158if (_responseDataPayloadRemaining <= 0 && !ReadNextDataFrameAsync(response, CancellationToken.None).AsTask().GetAwaiter().GetResult())

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

176LogExceptions(_readAheadTask.AsTask()); 216LogExceptions(_readAheadTask.AsTask()); 858LogExceptions(_readAheadTask.AsTask());

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

17sendTask.AsTask().GetAwaiter().GetResult(); 21SendAsync(request, async: true, cancellationToken).AsTask();

System.Net.Http.Json (1)

System\Net\Http\Json\LengthLimitReadStream.cs (1)

42ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

System.Net.Mail (1)

System\Net\DelegatedStream.cs (1)

144return ReadAsyncInternal(buffer.AsMemory(offset, count), cancellationToken).AsTask();

System.Net.Quic (2)

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

126int readLength = ReadAsync(new Memory<byte>(rentedBuffer, 0, buffer.Length), cts?.Token ?? default).AsTask().GetAwaiter().GetResult(); 146return ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

System.Net.Requests (1)

System\Net\HttpWebResponse.cs (1)

410return ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

System.Net.Security (3)

System\Net\Security\NegotiateStream.cs (1)

324return ReadAsync<AsyncReadWriteAdapter>(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

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

885return ReadAsyncInternal<AsyncReadWriteAdapter>(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

System\Net\Security\SslStreamCertificateContext.Linux.cs (1)

133GetOcspResponseAsync().AsTask();

System.Net.Sockets (17)

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

578cancellationToken).AsTask();

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

2495return TaskToAsyncResult.Begin(SendAsync(new ReadOnlyMemory<byte>(buffer, offset, size), socketFlags, default).AsTask(), callback, state); 2505Task<int> t = SendAsync(new ReadOnlyMemory<byte>(buffer, offset, size), socketFlags, default).AsTask(); 2580Task<int> t = SendToAsync(buffer.AsMemory(offset, size), socketFlags, remoteEP).AsTask(); 2592return TaskToAsyncResult.Begin(ReceiveAsync(new ArraySegment<byte>(buffer, offset, size), socketFlags, fromNetworkStream: false, default).AsTask(), callback, state); 2601Task<int> t = ReceiveAsync(new ArraySegment<byte>(buffer, offset, size), socketFlags, fromNetworkStream: false, default).AsTask(); 2671Task<SocketReceiveMessageFromResult> t = ReceiveMessageFromAsync(buffer.AsMemory(offset, size), socketFlags, remoteEP).AsTask(); 2712Task<SocketReceiveFromResult> t = ReceiveFromAsync(buffer.AsMemory(offset, size), socketFlags, remoteEP).AsTask();

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

32public Task<Socket> AcceptAsync() => AcceptAsync((Socket?)null, CancellationToken.None).AsTask(); 46public Task<Socket> AcceptAsync(Socket? acceptSocket) => AcceptAsync(acceptSocket, CancellationToken.None).AsTask(); 290return ReceiveAsync(buffer, socketFlags, fromNetworkStream, default).AsTask(); 379return ReceiveFromAsync(buffer, socketFlags, remoteEndPoint, default).AsTask(); 481return ReceiveMessageFromAsync(buffer, socketFlags, remoteEndPoint, default).AsTask(); 539return SendAsync(buffer, socketFlags, default).AsTask(); 643return SendToAsync(buffer, socketFlags, remoteEP, default).AsTask();

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

224public Task<Socket> AcceptSocketAsync() => AcceptSocketAsync(CancellationToken.None).AsTask(); 236public Task<TcpClient> AcceptTcpClientAsync() => AcceptTcpClientAsync(CancellationToken.None).AsTask();

System.Net.WebSockets (2)

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

373return ReceiveAsyncPrivate<WebSocketReceiveResult>(buffer, cancellationToken).AsTask(); 1155Task task = finalReadTask.AsTask();

System.Private.CoreLib (11)

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

625cancellationToken, bytesFromBuffer, semaphoreLockTask).AsTask();

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

289: readResult.AsTask();

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

270ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

src\libraries\System.Private.CoreLib\src\System\IO\StreamReader.cs (3)

855ReadLineAsync(default).AsTask(); 1070Task<int> task = ReadAsyncInternal(new Memory<char>(buffer, index, count), CancellationToken.None).AsTask(); 1310Task<int> t = vt.AsTask();

src\libraries\System.Private.CoreLib\src\System\IO\TextReader.cs (2)

271return ReadAsyncInternal(new Memory<char>(buffer, index, count), default).AsTask(); 301return ReadBlockAsyncInternal(new Memory<char>(buffer, index, count), default).AsTask();

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

364return ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();

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

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

System.Private.Xml (3)

System\Xml\Core\XmlTextReaderImplAsync.cs (3)

2907return _ParseTextAsync(parseTextTask.AsTask()); 2936return _ParseTextAsync(parseTextTask.AsTask()); 2969parseTask = ParseTextAsync(orChars).AsTask();

System.Security.Cryptography (1)

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

220return ReadAsyncInternal(buffer.AsMemory(offset, count), cancellationToken).AsTask();

System.ServiceModel.NetFramingBase (1)

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

232return Connection.ReadAsync(new Memory<byte>(buffer, offset, count), TimeoutHelper.FromMilliseconds(ReadTimeout)).AsTask();

System.Text.Json (1)

System\Text\Json\Serialization\Converters\Collection\IAsyncEnumerableOfTConverter.cs (1)

130state.PendingTask = moveNextTask.AsTask();

xunit.assert (1)

Sdk\AssertHelper.cs (1)

745 return Task.Run(valueTask.AsTask).GetAwaiter().GetResult();