116 instantiations of ValueTask
http2cat (1)
IIS.FunctionalTests (1)
IIS.LongTests (1)
IIS.NewHandler.FunctionalTests (1)
IIS.NewShim.FunctionalTests (1)
IIS.ShadowCopy.Tests (1)
IISExpress.FunctionalTests (1)
Microsoft.AspNetCore.Components.Server.Tests (1)
Microsoft.AspNetCore.Components.Tests (2)
Microsoft.AspNetCore.Components.WebAssembly.Tests (1)
Microsoft.AspNetCore.Grpc.JsonTranscoding (1)
Microsoft.AspNetCore.Http (1)
Microsoft.AspNetCore.Http.Abstractions (1)
Microsoft.AspNetCore.Http.Connections (2)
Microsoft.AspNetCore.Http.Connections.Client (1)
Microsoft.AspNetCore.Http.Extensions (1)
Microsoft.AspNetCore.Http.Extensions.Tests (3)
Microsoft.AspNetCore.Mvc.ApiExplorer.Test (1)
Microsoft.AspNetCore.Mvc.Core (1)
Microsoft.AspNetCore.OpenApi.Tests (1)
Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (1)
Microsoft.AspNetCore.Server.IIS (5)
Microsoft.AspNetCore.Server.Kestrel.Core (3)
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (3)
Microsoft.AspNetCore.Shared.Tests (1)
Microsoft.AspNetCore.SignalR.Client.Core (2)
Microsoft.AspNetCore.SignalR.Client.FunctionalTests (1)
Microsoft.AspNetCore.SignalR.Client.Tests (1)
Microsoft.AspNetCore.SignalR.Core (5)
Microsoft.AspNetCore.SignalR.Tests (1)
Microsoft.CodeAnalysis (1)
Microsoft.CodeAnalysis.CodeStyle (1)
src\Compilers\Core\Portable\InternalUtilities\ValueTaskFactory.cs (1)
20=> new();
Microsoft.CodeAnalysis.Features (6)
Microsoft.CodeAnalysis.LanguageServer.Protocol (1)
Microsoft.CodeAnalysis.Workspaces (1)
src\Compilers\Core\Portable\InternalUtilities\ValueTaskFactory.cs (1)
20=> new();
Microsoft.CodeAnalysis.Workspaces.MSBuild.BuildHost (1)
src\Compilers\Core\Portable\InternalUtilities\ValueTaskFactory.cs (1)
20=> new();
Microsoft.CommonLanguageServerProtocol.Framework.Package (1)
Microsoft.Extensions.Caching.Hybrid (3)
Microsoft.Extensions.Caching.Hybrid.Tests (1)
Microsoft.Extensions.Caching.StackExchangeRedis (1)
Microsoft.Extensions.DependencyInjection (1)
Shared (1)
System.IO.Pipelines (3)
System.IO.Pipes (1)
System.IO.Ports (1)
System.Net.Http (4)
System.Net.Quic (4)
System.Net.Security (2)
System.Net.Sockets (5)
System.Net.WebSockets (2)
System.Private.CoreLib (17)
System.ServiceModel.UnixDomainSocket (2)
System.Threading.Channels (9)
2564 references to ValueTask
Aspire.Azure.Messaging.EventHubs.Tests (1)
Aspire.Azure.Npgsql.EntityFrameworkCore.PostgreSQL.Tests (2)
Aspire.Azure.Npgsql.Tests (2)
Aspire.Azure.Security.KeyVault.Tests (1)
Aspire.Confluent.Kafka (4)
Aspire.Confluent.Kafka.Tests (2)
Aspire.Dashboard (22)
Aspire.Dashboard.Components.Tests (7)
Aspire.Dashboard.Tests (17)
Aspire.EndToEnd.Tests (4)
Aspire.Hosting (19)
Aspire.Hosting.Azure (1)
Aspire.Hosting.Kafka.Tests (2)
Aspire.Hosting.MySql.Tests (2)
Aspire.Hosting.NodeJs.Tests (4)
Aspire.Hosting.PostgreSQL.Tests (2)
Aspire.Hosting.RabbitMQ.Tests (2)
Aspire.Hosting.Testing (6)
Aspire.Hosting.Testing.Tests (2)
Aspire.Hosting.Tests (4)
Aspire.Hosting.Valkey.Tests (2)
Aspire.Microsoft.Data.SqlClient.Tests (2)
Aspire.Microsoft.EntityFrameworkCore.SqlServer.Tests (2)
Aspire.Milvus.Client.Tests (2)
Aspire.MongoDB.Driver.Tests (2)
Aspire.MongoDB.Driver.v3.Tests (2)
Aspire.MySqlConnector.Tests (2)
Aspire.NATS.Net.Tests (2)
Aspire.Npgsql.EntityFrameworkCore.PostgreSQL.Tests (2)
Aspire.Npgsql.Tests (2)
Aspire.Oracle.EntityFrameworkCore.Tests (2)
Aspire.Playground.Tests (2)
Aspire.Pomelo.EntityFrameworkCore.MySql.Tests (2)
Aspire.Qdrant.Client.Tests (2)
Aspire.RabbitMQ.Client.Tests (2)
Aspire.RabbitMQ.Client.v7.Tests (2)
Aspire.StackExchange.Redis.Tests (2)
Aspire.Templates.Tests (4)
BasicWebSite (1)
ClientSample (1)
CustomResources.AppHost (1)
GenerateDocumentationAndConfigFiles (1)
http2cat (3)
HttpLogging.Sample (2)
IIS.FunctionalTests (3)
IIS.LongTests (3)
IIS.NewHandler.FunctionalTests (3)
IIS.NewShim.FunctionalTests (3)
IIS.ShadowCopy.Tests (3)
IISExpress.FunctionalTests (3)
InMemory.FunctionalTests (21)
Interop.FunctionalTests (2)
Microsoft.AspNetCore (1)
Microsoft.AspNetCore.Components (19)
NavigationManager.cs (11)
34private readonly List<Func<LocationChangingContext, ValueTask>> _locationChangingHandlers = new();
386var handlerTask = InvokeLocationChangingHandlerAsync(_locationChangingHandlers[0], context);
406var locationChangingHandlersCopy = ArrayPool<Func<LocationChangingContext, ValueTask>>.Shared.Rent(handlerCount);
416var handlerTask = InvokeLocationChangingHandlerAsync(locationChangingHandlersCopy[i], context);
452ArrayPool<Func<LocationChangingContext, ValueTask>>.Shared.Return(locationChangingHandlersCopy);
481private async ValueTask InvokeLocationChangingHandlerAsync(Func<LocationChangingContext, ValueTask> handler, LocationChangingContext context)
519public IDisposable RegisterLocationChangingHandler(Func<LocationChangingContext, ValueTask> locationChangingHandler)
535private void RemoveLocationChangingHandler(Func<LocationChangingContext, ValueTask> locationChangingHandler)
602private readonly Func<LocationChangingContext, ValueTask> _handler;
605public LocationChangingRegistration(Func<LocationChangingContext, ValueTask> handler, NavigationManager navigationManager)
Microsoft.AspNetCore.Components.Authorization.Tests (1)
Microsoft.AspNetCore.Components.Endpoints (5)
Microsoft.AspNetCore.Components.Endpoints.Tests (2)
Microsoft.AspNetCore.Components.Forms.Tests (1)
Microsoft.AspNetCore.Components.QuickGrid (1)
Microsoft.AspNetCore.Components.Server (22)
ComponentHub.cs (6)
220public async ValueTask BeginInvokeDotNetFromJS(string callId, string assemblyName, string methodIdentifier, long dotNetObjectId, string argsJson)
231public async ValueTask EndInvokeJSFromDotNet(long asyncHandle, bool succeeded, string arguments)
242public async ValueTask ReceiveByteArray(int id, byte[] data)
304public async ValueTask OnRenderCompleted(long renderId, string errorMessageOrNull)
316public async ValueTask OnLocationChanged(string uri, string? state, bool intercepted)
327public async ValueTask OnLocationChanging(int callId, string uri, string? state, bool intercepted)
Microsoft.AspNetCore.Components.Server.Tests (11)
Microsoft.AspNetCore.Components.Tests (44)
RendererTest.cs (13)
2320builder.AddComponentParameter(1, nameof(AsyncDisposableComponent.AsyncDisposeAction), (Func<ValueTask>)(() => throw exception1));
2354builder.AddComponentParameter(1, nameof(AsyncDisposableComponent.AsyncDisposeAction), (Func<ValueTask>)(() => default));
2394builder.AddComponentParameter(1, nameof(AsyncDisposableComponent.AsyncDisposeAction), (Func<ValueTask>)(async () => { await tcs.Task; }));
2439builder.AddComponentParameter(1, nameof(AsyncDisposableComponent.AsyncDisposeAction), (Func<ValueTask>)(async () => { await tcs.Task; throw exception1; }));
2478builder.AddComponentParameter(1, nameof(AsyncDisposableComponent.AsyncDisposeAction), (Func<ValueTask>)(() => throw new TaskCanceledException()));
2516(Func<ValueTask>)(() => new ValueTask(tcs.Task)));
4274builder.AddComponentParameter(1, nameof(AsyncDisposableComponent.AsyncDisposeAction), (Func<ValueTask>)(() => { disposed = true; throw exception1; }));
4302builder.AddComponentParameter(1, nameof(AsyncDisposableComponent.AsyncDisposeAction), (Func<ValueTask>)(async () => { await tcs.Task; disposed = true; throw exception1; }));
4309var disposal = renderer.DisposeAsync();
4911builder.AddComponentParameter(1, nameof(AsyncDisposableComponent.AsyncDisposeAction), (Func<ValueTask>)(async () => await exception2Tcs.Task));
4971return ValueTask.CompletedTask;
5546public Func<ValueTask> AsyncDisposeAction { get; set; }
5548public ValueTask DisposeAsync()
Microsoft.AspNetCore.Components.Web (18)
Microsoft.AspNetCore.Components.Web.Tests (4)
Microsoft.AspNetCore.Components.WebAssembly (6)
Microsoft.AspNetCore.Components.WebAssembly.Server (1)
Microsoft.AspNetCore.Components.WebAssembly.Tests (7)
Microsoft.AspNetCore.Components.WebView (7)
Microsoft.AspNetCore.Components.WebView.Test (2)
Microsoft.AspNetCore.Components.WebView.Wpf (2)
Microsoft.AspNetCore.ConcurrencyLimiter (3)
Microsoft.AspNetCore.Connections.Abstractions (7)
Microsoft.AspNetCore.Diagnostics.Middleware (2)
Microsoft.AspNetCore.Diagnostics.Tests (1)
Microsoft.AspNetCore.Grpc.JsonTranscoding (4)
Internal\JsonRequestHelpers.cs (3)
87public static async ValueTask SendErrorResponse(HttpResponse response, Encoding encoding, Metadata trailers, Status status, JsonSerializerOptions options)
166public static async ValueTask WriteResponseMessage(HttpResponse response, Encoding encoding, object responseBody, JsonSerializerOptions options, CancellationToken cancellationToken)
371public static async ValueTask SendMessage<TResponse>(JsonTranscodingServerCallContext serverCallContext, JsonSerializerOptions serializerOptions, TResponse message, CancellationToken cancellationToken) where TResponse : class
Microsoft.AspNetCore.Grpc.JsonTranscoding.Tests (2)
Microsoft.AspNetCore.Hosting (2)
Microsoft.AspNetCore.Hosting.Tests (1)
Microsoft.AspNetCore.Html.Abstractions (1)
Microsoft.AspNetCore.Http (6)
Microsoft.AspNetCore.Http.Abstractions (4)
Microsoft.AspNetCore.Http.Connections (8)
Microsoft.AspNetCore.Http.Connections.Client (8)
Microsoft.AspNetCore.Http.Connections.Tests (7)
Microsoft.AspNetCore.Http.Extensions (15)
Microsoft.AspNetCore.Http.Extensions.Tests (32)
Microsoft.AspNetCore.Http.Microbenchmarks (1)
Microsoft.AspNetCore.Http.Tests (4)
Microsoft.AspNetCore.HttpLogging (9)
Microsoft.AspNetCore.HttpLogging.Tests (6)
Microsoft.AspNetCore.InternalTesting (2)
Microsoft.AspNetCore.Mvc.ApiExplorer (1)
Microsoft.AspNetCore.Mvc.ApiExplorer.Test (2)
Microsoft.AspNetCore.Mvc.Core (36)
Controllers\ControllerActivatorProvider.cs (6)
16private static readonly Func<ControllerContext, object, ValueTask> _disposeAsync = DisposeAsync;
17private static readonly Func<ControllerContext, object, ValueTask> _syncDisposeAsync = SyncDisposeAsync;
20private readonly Func<ControllerContext, object, ValueTask>? _controllerActivatorReleaseAsync;
81public Func<ControllerContext, object, ValueTask>? CreateAsyncReleaser(ControllerActionDescriptor descriptor)
110private static ValueTask DisposeAsync(ControllerContext context, object controller)
117private static ValueTask SyncDisposeAsync(ControllerContext context, object controller)
Microsoft.AspNetCore.Mvc.Core.Test (11)
Microsoft.AspNetCore.Mvc.Formatters.Xml.Test (2)
Microsoft.AspNetCore.Mvc.FunctionalTests (2)
Microsoft.AspNetCore.Mvc.NewtonsoftJson.Test (1)
Microsoft.AspNetCore.Mvc.RazorPages (22)
Infrastructure\DefaultPageActivatorProvider.cs (5)
16private readonly Func<PageContext, ViewContext, object, ValueTask> _asyncDisposer = AsyncDispose;
17private readonly Func<PageContext, ViewContext, object, ValueTask> _syncAsyncDisposer = SyncAsyncDispose;
48public Func<PageContext, ViewContext, object, ValueTask>? CreateAsyncReleaser(CompiledPageActionDescriptor actionDescriptor)
89private static ValueTask SyncAsyncDispose(PageContext context, ViewContext viewContext, object page)
95private static ValueTask AsyncDispose(PageContext context, ViewContext viewContext, object page)
Infrastructure\PageActionInvokerCacheEntry.cs (4)
18Func<PageContext, ViewContext, object, ValueTask>? releasePage,
20Func<PageContext, object, ValueTask>? releaseModel,
47public Func<PageContext, ViewContext, object, ValueTask>? ReleasePage { get; }
54public Func<PageContext, object, ValueTask>? ReleaseModel { get; }
Microsoft.AspNetCore.Mvc.RazorPages.Test (9)
Infrastructure\PageActionInvokerProviderTest.cs (3)
37Func<PageContext, ViewContext, object, ValueTask> releaser = (a, b, c) => default;
89Func<PageContext, ViewContext, object, ValueTask> releaser = (a, b, c) => default;
91Func<PageContext, object, ValueTask> modelDisposer = (_, __) => default;
Microsoft.AspNetCore.Mvc.Testing (2)
Microsoft.AspNetCore.Mvc.ViewFeatures (6)
Microsoft.AspNetCore.Mvc.ViewFeatures.Test (6)
Microsoft.AspNetCore.OpenApi (6)
Microsoft.AspNetCore.OpenApi.Tests (9)
Microsoft.AspNetCore.OutputCaching (132)
Microsoft.AspNetCore.OutputCaching.Microbenchmarks (3)
Microsoft.AspNetCore.OutputCaching.StackExchangeRedis (3)
Microsoft.AspNetCore.OutputCaching.Tests (23)
TestUtils.cs (12)
333public ValueTask EvictByTagAsync(string tag, CancellationToken cancellationToken)
347return ValueTask.FromResult(_storage[key]);
351return ValueTask.FromResult(default(byte[]));
356public ValueTask SetAsync(string key, byte[] entry, string[]? tags, TimeSpan validFor, CancellationToken cancellationToken)
363return ValueTask.CompletedTask;
370ValueTask IOutputCacheBufferStore.SetAsync(string key, ReadOnlySequence<byte> value, ReadOnlyMemory<string> tags, TimeSpan validFor, CancellationToken cancellationToken)
387public ValueTask CacheRequestAsync(OutputCacheContext context, CancellationToken cancellationToken)
391return ValueTask.CompletedTask;
394public ValueTask ServeFromCacheAsync(OutputCacheContext context, CancellationToken cancellationToken)
396return ValueTask.CompletedTask;
399public ValueTask ServeResponseAsync(OutputCacheContext context, CancellationToken cancellationToken)
401return ValueTask.CompletedTask;
Microsoft.AspNetCore.RateLimiting (6)
Microsoft.AspNetCore.RateLimiting.Tests (17)
Microsoft.AspNetCore.ResponseCaching (2)
Microsoft.AspNetCore.ResponseCaching.Microbenchmarks (3)
Microsoft.AspNetCore.ResponseCompression (1)
Microsoft.AspNetCore.ResponseCompression.Tests (2)
Microsoft.AspNetCore.Routing (1)
Microsoft.AspNetCore.Server.HttpSys (3)
Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (3)
Microsoft.AspNetCore.Server.IIS (13)
Microsoft.AspNetCore.Server.Kestrel.Core (54)
Internal\Http3\Http3ControlStream.cs (8)
136internal async ValueTask ProcessOutboundSendsAsync(long id)
314private async ValueTask HandleEncodingDecodingTask()
328private ValueTask ProcessHttp3ControlStream(Http3RawFrame incomingFrame, bool isContinuedFrame, in ReadOnlySequence<byte> payload, out SequencePosition consumed)
364private ValueTask ProcessSettingsFrameAsync(bool isContinuedFrame, ReadOnlySequence<byte> payload, out SequencePosition consumed)
431private ValueTask ProcessGoAwayFrameAsync(bool isContinuedFrame, Http3RawFrame incomingFrame, ReadOnlySequence<byte> payload, out SequencePosition consumed)
453private ValueTask ProcessCancelPushFrameAsync(Http3RawFrame incomingFrame, ReadOnlySequence<byte> payload, out SequencePosition consumed)
465private ValueTask ProcessMaxPushIdFrameAsync(Http3RawFrame incomingFrame, ReadOnlySequence<byte> payload, out SequencePosition consumed)
477private ValueTask ProcessUnknownFrameAsync(Http3FrameType frameType)
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (11)
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (7)
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (3)
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (18)
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic.Tests (6)
Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets (4)
Microsoft.AspNetCore.Shared.Tests (15)
Microsoft.AspNetCore.SignalR.Client.Core (12)
Microsoft.AspNetCore.SignalR.Client.FunctionalTests (1)
Microsoft.AspNetCore.SignalR.Client.Tests (12)
Microsoft.AspNetCore.SignalR.Core (24)
Microsoft.AspNetCore.SignalR.Microbenchmarks (1)
Microsoft.AspNetCore.SignalR.Specification.Tests (3)
Microsoft.AspNetCore.SignalR.StackExchangeRedis.Tests (1)
Microsoft.AspNetCore.SignalR.Tests (8)
Microsoft.AspNetCore.SignalR.Tests.Utils (3)
Microsoft.AspNetCore.TestHost (4)
Microsoft.AspNetCore.TestHost.Tests (1)
Microsoft.AspNetCore.WebSockets (2)
Microsoft.AspNetCore.WebSockets.Tests (3)
Microsoft.AspNetCore.WebUtilities (7)
Microsoft.AspNetCore.WebUtilities.Tests (2)
Microsoft.Build (1)
Microsoft.CodeAnalysis (2)
Microsoft.CodeAnalysis.CodeStyle (33)
src\Dependencies\Threading\AsyncBatchingWorkQueue`1.cs (3)
17Func<ImmutableSegmentedList<TItem>, CancellationToken, ValueTask> processBatchAsync,
24Func<ImmutableSegmentedList<TItem>, CancellationToken, ValueTask> processBatchAsync,
35private static Func<ImmutableSegmentedList<TItem>, CancellationToken, ValueTask<VoidResult>> Convert(Func<ImmutableSegmentedList<TItem>, CancellationToken, ValueTask> processBatchAsync)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\RoslynParallel.NetFramework.cs (14)
41public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask> body)
59public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, CancellationToken cancellationToken, Func<TSource, CancellationToken, ValueTask> body)
76public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)
113private static Task ForEachAsync<TSource>(IEnumerable<TSource> source, int dop, TaskScheduler scheduler, CancellationToken cancellationToken, Func<TSource, CancellationToken, ValueTask> body)
219public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask> body)
237public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, CancellationToken cancellationToken, Func<TSource, CancellationToken, ValueTask> body)
254public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)
278private static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, int dop, TaskScheduler scheduler, CancellationToken cancellationToken, Func<TSource, CancellationToken, ValueTask> body)
417public readonly Func<TSource, CancellationToken, ValueTask> LoopBody;
422protected ForEachAsyncState(Func<object, Task> taskBody, bool needsLock, int dop, TaskScheduler scheduler, CancellationToken cancellationToken, Func<TSource, CancellationToken, ValueTask> body)
590Func<TSource, CancellationToken, ValueTask> body) :
616Func<TSource, CancellationToken, ValueTask> body) :
626public ValueTask DisposeAsync()
643Func<T, CancellationToken, ValueTask> body) :
Microsoft.CodeAnalysis.CodeStyle.Fixes (7)
Microsoft.CodeAnalysis.CSharp.CodeStyle (1)
Microsoft.CodeAnalysis.CSharp.CodeStyle.Fixes (4)
Microsoft.CodeAnalysis.CSharp.EditorFeatures.UnitTests (1)
Microsoft.CodeAnalysis.CSharp.Features (4)
Microsoft.CodeAnalysis.CSharp.Features.UnitTests (4)
Microsoft.CodeAnalysis.CSharp.Workspaces (1)
Microsoft.CodeAnalysis.EditorFeatures (63)
Microsoft.CodeAnalysis.EditorFeatures.Test.Utilities (4)
Microsoft.CodeAnalysis.EditorFeatures.UnitTests (1)
Microsoft.CodeAnalysis.ExternalAccess.Copilot (10)
Microsoft.CodeAnalysis.ExternalAccess.Razor.Features (20)
Remote\RazorRemoteHostClient.cs (4)
40public async ValueTask<bool> TryInvokeAsync<TService>(Func<TService, CancellationToken, ValueTask> invocation, CancellationToken cancellationToken) where TService : class
54public async ValueTask<bool> TryInvokeAsync<TService>(Func<TService, RazorRemoteServiceCallbackIdWrapper, CancellationToken, ValueTask> invocation, object callbackTarget, CancellationToken cancellationToken) where TService : class
68public async ValueTask<bool> TryInvokeAsync<TService>(Solution solution, Func<TService, RazorPinnedSolutionInfoWrapper, CancellationToken, ValueTask> invocation, CancellationToken cancellationToken) where TService : class
82public async ValueTask<bool> TryInvokeAsync<TService>(Solution solution, Func<TService, RazorPinnedSolutionInfoWrapper, RazorRemoteServiceCallbackIdWrapper, CancellationToken, ValueTask> invocation, object callbackTarget, CancellationToken cancellationToken) where TService : class
Remote\RazorRemoteServiceConnectionWrapper.cs (4)
25public ValueTask<bool> TryInvokeAsync(Func<TService, CancellationToken, ValueTask> invocation, CancellationToken cancellationToken)
33public ValueTask<bool> TryInvokeAsync(Func<TService, RazorRemoteServiceCallbackIdWrapper, CancellationToken, ValueTask> invocation, CancellationToken cancellationToken)
45public ValueTask<bool> TryInvokeAsync(Solution solution, Func<TService, RazorPinnedSolutionInfoWrapper, CancellationToken, ValueTask> invocation, CancellationToken cancellationToken)
59public ValueTask<bool> TryInvokeAsync(Solution solution, Func<TService, RazorPinnedSolutionInfoWrapper, RazorRemoteServiceCallbackIdWrapper, CancellationToken, ValueTask> invocation, CancellationToken cancellationToken)
Microsoft.CodeAnalysis.ExternalAccess.Xaml (4)
Microsoft.CodeAnalysis.Features (189)
EditAndContinue\Remote\IRemoteEditAndContinueService.cs (7)
23ValueTask PrepareModuleForUpdateAsync(RemoteServiceCallbackId callbackId, Guid mvid, CancellationToken cancellationToken);
35ValueTask CommitSolutionUpdateAsync(DebuggingSessionId sessionId, CancellationToken cancellationToken);
36ValueTask DiscardSolutionUpdateAsync(DebuggingSessionId sessionId, CancellationToken cancellationToken);
37ValueTask UpdateBaselinesAsync(Checksum solutionInfo, DebuggingSessionId sessionId, ImmutableArray<ProjectId> rebuiltProjects, CancellationToken cancellationToken);
44ValueTask BreakStateOrCapabilitiesChangedAsync(DebuggingSessionId sessionId, bool? isBreakState, CancellationToken cancellationToken);
49ValueTask EndDebuggingSessionAsync(DebuggingSessionId sessionId, CancellationToken cancellationToken);
53ValueTask SetFileLoggingDirectoryAsync(string? logDirectory, CancellationToken cancellationToken);
EditAndContinue\TraceLog.cs (4)
92public async ValueTask WriteAsync(Func<Stream, CancellationToken, ValueTask> writer, DebuggingSessionId sessionId, string directory, string fileName, CancellationToken cancellationToken)
107public async ValueTask WriteDocumentAsync(Document document, string fileNameSuffix, UpdateId updateId, int? generation, CancellationToken cancellationToken)
126public async ValueTask WriteDocumentChangeAsync(Document? oldDocument, Document? newDocument, UpdateId updateId, int? generation, CancellationToken cancellationToken)
Extensions\ExtensionMessageHandlerService_RemoteOrLocal.cs (6)
19private async ValueTask ExecuteActionInRemoteOrCurrentProcessAsync<TArg>(
21Func<ExtensionMessageHandlerService, TArg, CancellationToken, ValueTask> executeInProcessAsync,
22Func<IRemoteExtensionMessageHandlerService, TArg, Checksum?, CancellationToken, ValueTask> executeOutOfProcessAsync,
70public ValueTask RegisterExtensionAsync(string assemblyFilePath, CancellationToken cancellationToken)
78public ValueTask UnregisterExtensionAsync(string assemblyFilePath, CancellationToken cancellationToken)
94public ValueTask ResetAsync(CancellationToken cancellationToken)
FindUsages\IRemoteFindUsagesService.cs (23)
27ValueTask AddItemsAsync(RemoteServiceCallbackId callbackId, int count, CancellationToken cancellationToken);
28ValueTask ItemsCompletedAsync(RemoteServiceCallbackId callbackId, int count, CancellationToken cancellationToken);
29ValueTask ReportMessageAsync(RemoteServiceCallbackId callbackId, string message, CancellationToken cancellationToken);
30ValueTask ReportInformationalMessageAsync(RemoteServiceCallbackId callbackId, string message, CancellationToken cancellationToken);
31ValueTask SetSearchTitleAsync(RemoteServiceCallbackId callbackId, string title, CancellationToken cancellationToken);
32ValueTask OnDefinitionFoundAsync(RemoteServiceCallbackId callbackId, SerializableDefinitionItem definition, CancellationToken cancellationToken);
33ValueTask OnReferencesFoundAsync(RemoteServiceCallbackId callbackId, ImmutableArray<SerializableSourceReferenceItem> references, CancellationToken cancellationToken);
36ValueTask FindReferencesAsync(
43ValueTask FindImplementationsAsync(
65public ValueTask AddItemsAsync(RemoteServiceCallbackId callbackId, int count, CancellationToken cancellationToken)
68public ValueTask ItemsCompletedAsync(RemoteServiceCallbackId callbackId, int count, CancellationToken cancellationToken)
71public ValueTask OnDefinitionFoundAsync(RemoteServiceCallbackId callbackId, SerializableDefinitionItem definition, CancellationToken cancellationToken)
74public ValueTask OnReferencesFoundAsync(RemoteServiceCallbackId callbackId, ImmutableArray<SerializableSourceReferenceItem> references, CancellationToken cancellationToken)
77public ValueTask ReportMessageAsync(RemoteServiceCallbackId callbackId, string message, CancellationToken cancellationToken)
80public ValueTask ReportInformationalMessageAsync(RemoteServiceCallbackId callbackId, string message, CancellationToken cancellationToken)
83public ValueTask SetSearchTitleAsync(RemoteServiceCallbackId callbackId, string title, CancellationToken cancellationToken)
97public ValueTask AddItemsAsync(int count, CancellationToken cancellationToken)
100public ValueTask ItemsCompletedAsync(int count, CancellationToken cancellationToken)
103public ValueTask ReportMessageAsync(string message, CancellationToken cancellationToken)
106public ValueTask ReportInformationalMessageAsync(string message, CancellationToken cancellationToken)
109public ValueTask SetSearchTitleAsync(string title, CancellationToken cancellationToken)
112public async ValueTask OnDefinitionFoundAsync(SerializableDefinitionItem definition, CancellationToken cancellationToken)
132public async ValueTask OnReferencesFoundAsync(ImmutableArray<SerializableSourceReferenceItem> references, CancellationToken cancellationToken)
NavigateTo\IRemoteNavigateToSearchService.cs (11)
20ValueTask SearchDocumentAndRelatedDocumentsAsync(Checksum solutionChecksum, DocumentId documentId, string searchPattern, ImmutableArray<string> kinds, RemoteServiceCallbackId callbackId, CancellationToken cancellationToken);
21ValueTask SearchProjectsAsync(Checksum solutionChecksum, ImmutableArray<ProjectId> projectIds, ImmutableArray<DocumentId> priorityDocumentIds, string searchPattern, ImmutableArray<string> kinds, RemoteServiceCallbackId callbackId, CancellationToken cancellationToken);
23ValueTask SearchGeneratedDocumentsAsync(Checksum solutionChecksum, ImmutableArray<ProjectId> projectIds, string searchPattern, ImmutableArray<string> kinds, RemoteServiceCallbackId callbackId, CancellationToken cancellationToken);
24ValueTask SearchCachedDocumentsAsync(ImmutableArray<DocumentKey> documentKeys, ImmutableArray<DocumentKey> priorityDocumentKeys, string searchPattern, ImmutableArray<string> kinds, RemoteServiceCallbackId callbackId, CancellationToken cancellationToken);
26ValueTask HydrateAsync(Checksum solutionChecksum, CancellationToken cancellationToken);
30ValueTask OnItemsFoundAsync(RemoteServiceCallbackId callbackId, ImmutableArray<RoslynNavigateToItem> items);
31ValueTask OnProjectCompletedAsync(RemoteServiceCallbackId callbackId);
43public ValueTask OnItemsFoundAsync(RemoteServiceCallbackId callbackId, ImmutableArray<RoslynNavigateToItem> items)
46public ValueTask OnProjectCompletedAsync(RemoteServiceCallbackId callbackId)
55public async ValueTask OnItemsFoundAsync(ImmutableArray<RoslynNavigateToItem> items)
66public async ValueTask OnProjectCompletedAsync()
SemanticSearch\IRemoteSemanticSearchService.cs (14)
22ValueTask OnDefinitionFoundAsync(RemoteServiceCallbackId callbackId, SerializableDefinitionItem definition, CancellationToken cancellationToken);
23ValueTask OnUserCodeExceptionAsync(RemoteServiceCallbackId callbackId, UserCodeExceptionInfo exception, CancellationToken cancellationToken);
25ValueTask AddItemsAsync(RemoteServiceCallbackId callbackId, int itemCount, CancellationToken cancellationToken);
26ValueTask ItemsCompletedAsync(RemoteServiceCallbackId callbackId, int itemCount, CancellationToken cancellationToken);
31ValueTask DiscardQueryAsync(CompiledQueryId queryId, CancellationToken cancellationToken);
41public ValueTask OnDefinitionFoundAsync(RemoteServiceCallbackId callbackId, SerializableDefinitionItem definition, CancellationToken cancellationToken)
44public ValueTask OnUserCodeExceptionAsync(RemoteServiceCallbackId callbackId, UserCodeExceptionInfo exception, CancellationToken cancellationToken)
47public ValueTask AddItemsAsync(RemoteServiceCallbackId callbackId, int itemCount, CancellationToken cancellationToken)
50public ValueTask ItemsCompletedAsync(RemoteServiceCallbackId callbackId, int itemCount, CancellationToken cancellationToken)
59public async ValueTask OnDefinitionFoundAsync(SerializableDefinitionItem definition, CancellationToken cancellationToken)
71public async ValueTask OnUserCodeExceptionAsync(UserCodeExceptionInfo exception, CancellationToken cancellationToken)
82public async ValueTask AddItemsAsync(int itemCount, CancellationToken cancellationToken)
93public async ValueTask ItemsCompletedAsync(int itemCount, CancellationToken cancellationToken)
132public static async ValueTask DiscardQueryAsync(SolutionServices services, CompiledQueryId queryId, CancellationToken cancellationToken)
Microsoft.CodeAnalysis.Features.Test.Utilities (1)
Microsoft.CodeAnalysis.InteractiveHost (11)
src\Dependencies\Threading\AsyncBatchingWorkQueue`1.cs (3)
17Func<ImmutableSegmentedList<TItem>, CancellationToken, ValueTask> processBatchAsync,
24Func<ImmutableSegmentedList<TItem>, CancellationToken, ValueTask> processBatchAsync,
35private static Func<ImmutableSegmentedList<TItem>, CancellationToken, ValueTask<VoidResult>> Convert(Func<ImmutableSegmentedList<TItem>, CancellationToken, ValueTask> processBatchAsync)
Microsoft.CodeAnalysis.LanguageServer (6)
Microsoft.CodeAnalysis.LanguageServer.Protocol (35)
Microsoft.CodeAnalysis.LanguageServer.UnitTests (3)
Microsoft.CodeAnalysis.Remote.ServiceHub (85)
Services\BrokeredServiceBase.cs (8)
124protected static ValueTask RunServiceAsync(Func<CancellationToken, ValueTask> implementation, CancellationToken cancellationToken)
129protected ValueTask RunServiceAsync(
130Checksum solutionChecksum, Func<Solution, ValueTask> implementation, CancellationToken cancellationToken)
146protected ValueTask RunServiceAsync(
149Func<Solution, Solution, ValueTask> implementation,
161internal static async ValueTask RunServiceImplAsync(Func<CancellationToken, ValueTask> implementation, CancellationToken cancellationToken)
Services\EditAndContinue\RemoteEditAndContinueService.cs (7)
48ValueTask IManagedHotReloadService.PrepareModuleForUpdateAsync(Guid moduleVersionId, CancellationToken cancellationToken)
99public ValueTask BreakStateOrCapabilitiesChangedAsync(DebuggingSessionId sessionId, bool? inBreakState, CancellationToken cancellationToken)
111public ValueTask EndDebuggingSessionAsync(DebuggingSessionId sessionId, CancellationToken cancellationToken)
180public ValueTask CommitSolutionUpdateAsync(DebuggingSessionId sessionId, CancellationToken cancellationToken)
192public ValueTask DiscardSolutionUpdateAsync(DebuggingSessionId sessionId, CancellationToken cancellationToken)
204public ValueTask UpdateBaselinesAsync(Checksum solutionChecksum, DebuggingSessionId sessionId, ImmutableArray<ProjectId> rebuiltProjects, CancellationToken cancellationToken)
239public ValueTask SetFileLoggingDirectoryAsync(string? logDirectory, CancellationToken cancellationToken)
Services\SymbolFinder\RemoteSymbolFinderService.cs (11)
34public ValueTask FindReferencesAsync(
69public ValueTask FindLiteralReferencesAsync(Checksum solutionChecksum, RemoteServiceCallbackId callbackId, object value, TypeCode typeCode, CancellationToken cancellationToken)
187public ValueTask OnReferenceFoundAsync(Document document, TextSpan span, CancellationToken cancellationToken)
190public ValueTask AddItemsAsync(int count, CancellationToken cancellationToken)
193public ValueTask ItemsCompletedAsync(int count, CancellationToken cancellationToken)
213public ValueTask OnStartedAsync(CancellationToken cancellationToken)
216public ValueTask OnCompletedAsync(CancellationToken cancellationToken)
219public ValueTask OnDefinitionFoundAsync(SymbolGroup group, CancellationToken cancellationToken)
226public async ValueTask OnReferencesFoundAsync(
242public ValueTask AddItemsAsync(int count, CancellationToken cancellationToken)
245public ValueTask ItemsCompletedAsync(int count, CancellationToken cancellationToken)
Microsoft.CodeAnalysis.Remote.Workspaces (56)
BrokeredServiceConnection.cs (7)
98public override async ValueTask<bool> TryInvokeAsync(Func<TService, CancellationToken, ValueTask> invocation, CancellationToken cancellationToken)
129public override async ValueTask<bool> TryInvokeAsync(Func<TService, RemoteServiceCallbackId, CancellationToken, ValueTask> invocation, CancellationToken cancellationToken)
164public override async ValueTask<bool> TryInvokeAsync(SolutionCompilationState compilationState, Func<TService, Checksum, CancellationToken, ValueTask> invocation, CancellationToken cancellationToken)
197public override async ValueTask<bool> TryInvokeAsync(SolutionCompilationState compilationState, ProjectId projectId, Func<TService, Checksum, CancellationToken, ValueTask> invocation, CancellationToken cancellationToken)
230public override async ValueTask<bool> TryInvokeAsync(SolutionCompilationState compilationState, Func<TService, Checksum, RemoteServiceCallbackId, CancellationToken, ValueTask> invocation, CancellationToken cancellationToken)
268public override async ValueTask<bool> TryInvokeAsync(SolutionCompilationState compilationState, ProjectId projectId, Func<TService, Checksum, RemoteServiceCallbackId, CancellationToken, ValueTask> invocation, CancellationToken cancellationToken)
306public override async ValueTask<bool> TryInvokeAsync(SolutionCompilationState compilationState1, SolutionCompilationState compilationState2, Func<TService, Checksum, Checksum, CancellationToken, ValueTask> invocation, CancellationToken cancellationToken)
ExternalAccess\Pythia\Api\PythiaRemoteHostClient.cs (4)
40public async ValueTask<bool> TryInvokeAsync<TService>(Func<TService, CancellationToken, ValueTask> invocation, CancellationToken cancellationToken) where TService : class
54public async ValueTask<bool> TryInvokeAsync<TService>(Func<TService, PythiaRemoteServiceCallbackIdWrapper, CancellationToken, ValueTask> invocation, object callbackTarget, CancellationToken cancellationToken) where TService : class
68public async ValueTask<bool> TryInvokeAsync<TService>(Solution solution, Func<TService, PythiaPinnedSolutionInfoWrapper, CancellationToken, ValueTask> invocation, CancellationToken cancellationToken) where TService : class
82public async ValueTask<bool> TryInvokeAsync<TService>(Solution solution, Func<TService, PythiaPinnedSolutionInfoWrapper, PythiaRemoteServiceCallbackIdWrapper, CancellationToken, ValueTask> invocation, object callbackTarget, CancellationToken cancellationToken) where TService : class
ExternalAccess\Pythia\Api\PythiaRemoteServiceConnectionWrapper.cs (4)
25public ValueTask<bool> TryInvokeAsync(Func<TService, CancellationToken, ValueTask> invocation, CancellationToken cancellationToken)
33public ValueTask<bool> TryInvokeAsync(Func<TService, PythiaRemoteServiceCallbackIdWrapper, CancellationToken, ValueTask> invocation, CancellationToken cancellationToken)
45public ValueTask<bool> TryInvokeAsync(Solution solution, Func<TService, PythiaPinnedSolutionInfoWrapper, CancellationToken, ValueTask> invocation, CancellationToken cancellationToken)
59public ValueTask<bool> TryInvokeAsync(Solution solution, Func<TService, PythiaPinnedSolutionInfoWrapper, PythiaRemoteServiceCallbackIdWrapper, CancellationToken, ValueTask> invocation, CancellationToken cancellationToken)
ExternalAccess\UnitTesting\Api\UnitTestingRemoteHostClient.cs (4)
40public async ValueTask<bool> TryInvokeAsync<TService>(Func<TService, CancellationToken, ValueTask> invocation, CancellationToken cancellationToken) where TService : class
54public async ValueTask<bool> TryInvokeAsync<TService>(Func<TService, UnitTestingRemoteServiceCallbackIdWrapper, CancellationToken, ValueTask> invocation, object callbackTarget, CancellationToken cancellationToken) where TService : class
68public async ValueTask<bool> TryInvokeAsync<TService>(Solution solution, Func<TService, UnitTestingPinnedSolutionInfoWrapper, CancellationToken, ValueTask> invocation, CancellationToken cancellationToken) where TService : class
82public async ValueTask<bool> TryInvokeAsync<TService>(Solution solution, Func<TService, UnitTestingPinnedSolutionInfoWrapper, UnitTestingRemoteServiceCallbackIdWrapper, CancellationToken, ValueTask> invocation, object callbackTarget, CancellationToken cancellationToken) where TService : class
ExternalAccess\UnitTesting\Api\UnitTestingRemoteServiceConnectionWrapper.cs (4)
25public ValueTask<bool> TryInvokeAsync(Func<TService, CancellationToken, ValueTask> invocation, CancellationToken cancellationToken)
33public ValueTask<bool> TryInvokeAsync(Func<TService, UnitTestingRemoteServiceCallbackIdWrapper, CancellationToken, ValueTask> invocation, CancellationToken cancellationToken)
45public ValueTask<bool> TryInvokeAsync(Solution solution, Func<TService, UnitTestingPinnedSolutionInfoWrapper, CancellationToken, ValueTask> invocation, CancellationToken cancellationToken)
59public ValueTask<bool> TryInvokeAsync(Solution solution, Func<TService, UnitTestingPinnedSolutionInfoWrapper, UnitTestingRemoteServiceCallbackIdWrapper, CancellationToken, ValueTask> invocation, CancellationToken cancellationToken)
RemoteCallback.cs (7)
34public static async ValueTask InvokeServiceAsync(
37Func<RemoteCallback<T>, CancellationToken, ValueTask> invocation,
61public async ValueTask InvokeAsync(Func<T, CancellationToken, ValueTask> invocation, CancellationToken cancellationToken)
98public async ValueTask InvokeAsync(
99Func<T, PipeWriter, CancellationToken, ValueTask> invocation,
100Func<PipeReader, CancellationToken, ValueTask> reader,
Microsoft.CodeAnalysis.Threading.Package (11)
AsyncBatchingWorkQueue`1.cs (3)
17Func<ImmutableSegmentedList<TItem>, CancellationToken, ValueTask> processBatchAsync,
24Func<ImmutableSegmentedList<TItem>, CancellationToken, ValueTask> processBatchAsync,
35private static Func<ImmutableSegmentedList<TItem>, CancellationToken, ValueTask<VoidResult>> Convert(Func<ImmutableSegmentedList<TItem>, CancellationToken, ValueTask> processBatchAsync)
Microsoft.CodeAnalysis.Workspaces (136)
FindSymbols\IRemoteSymbolFinderService.cs (11)
18ValueTask AddReferenceItemsAsync(RemoteServiceCallbackId callbackId, int count, CancellationToken cancellationToken);
19ValueTask ReferenceItemsCompletedAsync(RemoteServiceCallbackId callbackId, int count, CancellationToken cancellationToken);
20ValueTask OnStartedAsync(RemoteServiceCallbackId callbackId, CancellationToken cancellationToken);
21ValueTask OnCompletedAsync(RemoteServiceCallbackId callbackId, CancellationToken cancellationToken);
22ValueTask OnDefinitionFoundAsync(RemoteServiceCallbackId callbackId, SerializableSymbolGroup group, CancellationToken cancellationToken);
23ValueTask OnReferencesFoundAsync(RemoteServiceCallbackId callbackId, ImmutableArray<(SerializableSymbolGroup group, SerializableSymbolAndProjectId definition, SerializableReferenceLocation reference)> references, CancellationToken cancellationToken);
25ValueTask AddLiteralItemsAsync(RemoteServiceCallbackId callbackId, int count, CancellationToken cancellationToken);
26ValueTask LiteralItemsCompletedAsync(RemoteServiceCallbackId callbackId, int count, CancellationToken cancellationToken);
27ValueTask OnLiteralReferenceFoundAsync(RemoteServiceCallbackId callbackId, DocumentId documentId, TextSpan span, CancellationToken cancellationToken);
30ValueTask FindReferencesAsync(Checksum solutionChecksum, RemoteServiceCallbackId callbackId, SerializableSymbolAndProjectId symbolAndProjectIdArg, ImmutableArray<DocumentId> documentArgs,
33ValueTask FindLiteralReferencesAsync(Checksum solutionChecksum, RemoteServiceCallbackId callbackId, object value, TypeCode typeCode, CancellationToken cancellationToken);
FindSymbols\SymbolFinder.CallbackDispatcher.cs (9)
35public ValueTask AddReferenceItemsAsync(RemoteServiceCallbackId callbackId, int count, CancellationToken cancellationToken)
38public ValueTask ReferenceItemsCompletedAsync(RemoteServiceCallbackId callbackId, int count, CancellationToken cancellationToken)
41public ValueTask OnCompletedAsync(RemoteServiceCallbackId callbackId, CancellationToken cancellationToken)
44public ValueTask OnDefinitionFoundAsync(RemoteServiceCallbackId callbackId, SerializableSymbolGroup symbolGroup, CancellationToken cancellationToken)
47public ValueTask OnReferencesFoundAsync(RemoteServiceCallbackId callbackId, ImmutableArray<(SerializableSymbolGroup group, SerializableSymbolAndProjectId definition, SerializableReferenceLocation reference)> references, CancellationToken cancellationToken)
50public ValueTask OnStartedAsync(RemoteServiceCallbackId callbackId, CancellationToken cancellationToken)
55public ValueTask AddLiteralItemsAsync(RemoteServiceCallbackId callbackId, int count, CancellationToken cancellationToken)
58public ValueTask LiteralItemsCompletedAsync(RemoteServiceCallbackId callbackId, int count, CancellationToken cancellationToken)
61public ValueTask OnLiteralReferenceFoundAsync(RemoteServiceCallbackId callbackId, DocumentId documentId, TextSpan span, CancellationToken cancellationToken)
Remote\RemoteHostClient.cs (12)
61Func<TService, CancellationToken, ValueTask> invocation,
81Func<TService, RemoteServiceCallbackId, CancellationToken, ValueTask> invocation,
104Func<TService, Checksum, CancellationToken, ValueTask> invocation,
113Func<TService, Checksum, CancellationToken, ValueTask> invocation,
134/// Equivalent to <see cref="TryInvokeAsync{TService}(Solution, Func{TService, Checksum, CancellationToken, ValueTask}, CancellationToken)"/>
141Func<TService, Checksum, CancellationToken, ValueTask> invocation,
161/// Equivalent to <see cref="TryInvokeAsync{TService}(Solution, Func{TService, Checksum, CancellationToken, ValueTask}, CancellationToken)"/>
180Func<TService, Checksum, RemoteServiceCallbackId, CancellationToken, ValueTask> invocation,
203/// Equivalent to <see cref="TryInvokeAsync{TService}(Solution, Func{TService, Checksum, RemoteServiceCallbackId, CancellationToken, ValueTask}, object, CancellationToken)"/>
210Func<TService, Checksum, RemoteServiceCallbackId, CancellationToken, ValueTask> invocation,
220/// Equivalent to <see cref="TryInvokeAsync{TService}(Solution, Func{TService, Checksum, RemoteServiceCallbackId, CancellationToken, ValueTask}, object, CancellationToken)"/>
241Func<TService, Checksum, Checksum, CancellationToken, ValueTask> invocation,
Remote\RemoteServiceConnection.cs (12)
23Func<TService, CancellationToken, ValueTask> invocation,
33Func<TService, RemoteServiceCallbackId, CancellationToken, ValueTask> invocation,
44Func<TService, Checksum, CancellationToken, ValueTask> invocation,
54Func<TService, Checksum, CancellationToken, ValueTask> invocation,
69Func<TService, Checksum, CancellationToken, ValueTask> invocation,
80Func<TService, Checksum, CancellationToken, ValueTask> invocation,
94Func<TService, Checksum, RemoteServiceCallbackId, CancellationToken, ValueTask> invocation,
104Func<TService, Checksum, RemoteServiceCallbackId, CancellationToken, ValueTask> invocation,
119Func<TService, Checksum, RemoteServiceCallbackId, CancellationToken, ValueTask> invocation,
130Func<TService, Checksum, RemoteServiceCallbackId, CancellationToken, ValueTask> invocation,
145Func<TService, Checksum, Checksum, CancellationToken, ValueTask> invocation,
151Func<TService, Checksum, Checksum, CancellationToken, ValueTask> invocation,
src\Dependencies\Threading\AsyncBatchingWorkQueue`1.cs (3)
17Func<ImmutableSegmentedList<TItem>, CancellationToken, ValueTask> processBatchAsync,
24Func<ImmutableSegmentedList<TItem>, CancellationToken, ValueTask> processBatchAsync,
35private static Func<ImmutableSegmentedList<TItem>, CancellationToken, ValueTask<VoidResult>> Convert(Func<ImmutableSegmentedList<TItem>, CancellationToken, ValueTask> processBatchAsync)
Microsoft.CodeAnalysis.Workspaces.MSBuild (2)
Microsoft.CodeAnalysis.Workspaces.MSBuild.BuildHost (2)
Microsoft.CodeAnalysis.Workspaces.MSBuild.UnitTests (1)
Microsoft.CodeAnalysis.Workspaces.Test.Utilities (2)
Microsoft.CodeAnalysis.Workspaces.UnitTests (1)
Microsoft.CommonLanguageServerProtocol.Framework.Package (2)
Microsoft.DotNet.Helix.Client (1)
Microsoft.DotNet.Internal.SymbolHelper (6)
Microsoft.DotNet.XUnitAssert.Tests (1)
Microsoft.Extensions.AI (7)
Microsoft.Extensions.AI.AzureAIInference.Tests (2)
Microsoft.Extensions.AI.Evaluation (1)
Microsoft.Extensions.AI.Evaluation.Console (4)
Microsoft.Extensions.AI.Evaluation.Quality (2)
Microsoft.Extensions.AI.Evaluation.Reporting (19)
Microsoft.Extensions.AI.Evaluation.Reporting.Azure (6)
Microsoft.Extensions.AI.Evaluation.Safety (3)
Microsoft.Extensions.AI.Ollama (1)
Microsoft.Extensions.AI.Tests (4)
Microsoft.Extensions.Caching.Abstractions (8)
Hybrid\HybridCache.cs (7)
63public abstract ValueTask SetAsync<T>(string key, T value, HybridCacheEntryOptions? options = null, IEnumerable<string>? tags = null, CancellationToken cancellationToken = default);
68public abstract ValueTask RemoveAsync(string key, CancellationToken cancellationToken = default);
74public virtual ValueTask RemoveAsync(IEnumerable<string> keys, CancellationToken cancellationToken = default)
85static async ValueTask ForEachAsync(HybridCache @this, IEnumerable<string> keys, CancellationToken cancellationToken)
98public virtual ValueTask RemoveByTagAsync(IEnumerable<string> tags, CancellationToken cancellationToken = default)
109static async ValueTask ForEachAsync(HybridCache @this, IEnumerable<string> keys, CancellationToken cancellationToken)
121public abstract ValueTask RemoveByTagAsync(string tag, CancellationToken cancellationToken = default);
Microsoft.Extensions.Caching.Hybrid (10)
Internal\DefaultHybridCache.L2.cs (7)
81internal ValueTask SetL2Async(string key, CacheItem cacheItem, in BufferChunk buffer, HybridCacheEntryOptions? options, CancellationToken token)
84internal ValueTask SetDirectL2Async(string key, in BufferChunk buffer, DistributedCacheEntryOptions options, CancellationToken token)
107internal ValueTask InvalidateL2TagAsync(string tag, long timestamp, CancellationToken token)
116ValueTask pending = SetDirectL2Async(TagKeyPrefix + tag, new BufferChunk(oversized, 0, sizeof(long), false), _tagInvalidationEntryOptions, token);
129static async ValueTask AwaitedAsync(ValueTask pending, byte[] oversized)
224private async ValueTask WritePayloadAsync(string key, CacheItem cacheItem, BufferChunk payload, HybridCacheEntryOptions? options, CancellationToken token)
Microsoft.Extensions.Caching.Hybrid.Tests (5)
Microsoft.Extensions.Caching.SqlServer (1)
Microsoft.Extensions.Caching.StackExchangeRedis (1)
Microsoft.Extensions.Caching.StackExchangeRedis.Tests (3)
Microsoft.Extensions.DependencyInjection (5)
Microsoft.Extensions.DependencyInjection.Abstractions (1)
Microsoft.Extensions.Diagnostics.HealthChecks.Tests (2)
Microsoft.Extensions.Diagnostics.ResourceMonitoring (1)
Microsoft.Extensions.Diagnostics.ResourceMonitoring.Tests (6)
Microsoft.Extensions.Hosting (2)
Microsoft.Extensions.Http (2)
Microsoft.Extensions.Http.Diagnostics (3)
Microsoft.Extensions.Http.Diagnostics.PerformanceTests (1)
Microsoft.Extensions.Http.Diagnostics.Tests (1)
Microsoft.Extensions.ServiceDiscovery (9)
Microsoft.Extensions.ServiceDiscovery.Abstractions (1)
Microsoft.Extensions.ServiceDiscovery.Dns (2)
Microsoft.Extensions.ServiceDiscovery.Tests (4)
Microsoft.Extensions.TimeProvider.Testing (2)
Microsoft.JSInterop (28)
Microsoft.JSInterop.Tests (1)
Microsoft.Maui (1)
Microsoft.VisualStudio.LanguageServices (33)
FindReferences\Contexts\AbstractTableDataSourceFindUsagesContext.cs (10)
183protected abstract ValueTask OnDefinitionFoundWorkerAsync(DefinitionItem definition, CancellationToken cancellationToken);
184protected abstract ValueTask OnReferenceFoundWorkerAsync(SourceReferenceItem reference, CancellationToken cancellationToken);
349public sealed override ValueTask SetSearchTitleAsync(string title, CancellationToken cancellationToken)
356public sealed override async ValueTask OnCompletedAsync(CancellationToken cancellationToken)
362public sealed override ValueTask OnDefinitionFoundAsync(DefinitionItem definition, CancellationToken cancellationToken)
506public sealed override async ValueTask OnReferencesFoundAsync(IAsyncEnumerable<SourceReferenceItem> references, CancellationToken cancellationToken)
533public sealed override ValueTask ReportNoResultsAsync(string message, CancellationToken cancellationToken)
543public sealed override async ValueTask ReportMessageAsync(string message, NotificationSeverity severity, CancellationToken cancellationToken)
548protected sealed override ValueTask ReportProgressAsync(int current, int maximum, CancellationToken cancellationToken)
554private ValueTask UpdateTableProgressAsync(ImmutableSegmentedList<(int current, int maximum)> nextBatch, CancellationToken _)
Microsoft.VisualStudio.LanguageServices.CSharp (4)
Microsoft.VisualStudio.LanguageServices.CSharp.UnitTests (1)
Microsoft.VisualStudio.LanguageServices.DevKit (9)
MinimalSample (1)
mscorlib (1)
netstandard (1)
OrleansServer (1)
RateLimitingSample (3)
Roslyn.VisualStudio.Next.UnitTests (2)
Shared (2)
Sockets.BindTests (1)
Sockets.FunctionalTests (1)
Stress.AppHost (1)
System.Console (1)
System.Data.Common (11)
System.Formats.Tar (15)
System.IO.Compression (36)
System.IO.Compression.Brotli (5)
System.IO.Hashing (1)
System.IO.IsolatedStorage (2)
System.IO.Pipelines (8)
System.IO.Pipes (3)
System.IO.Ports (2)
System.Linq.AsyncEnumerable (1)
System.Memory.Data (1)
System.Net.Http (80)
System\Net\Http\SocketsHttpHandler\HttpConnection.cs (16)
968private async ValueTask SendRequestContentAsync(HttpRequestMessage request, HttpContentWriteStream stream, bool async, CancellationToken cancellationToken)
1410private ValueTask WriteAsync(ReadOnlyMemory<byte> source)
1427ValueTask flushTask = FlushAsync(async: true);
1450async ValueTask AwaitFlushAndWriteAsync(ValueTask flushTask, ReadOnlyMemory<byte> source)
1488private ValueTask WriteWithoutBufferingAsync(ReadOnlyMemory<byte> source, bool async)
1512private async ValueTask FlushThenWriteWithoutBufferingAsync(ReadOnlyMemory<byte> source, bool async)
1518private ValueTask WriteHexInt32Async(int value, bool async)
1555private ValueTask FlushAsync(bool async)
1572private ValueTask WriteToStreamAsync(ReadOnlyMemory<byte> source, bool async)
1622private async ValueTask InitialFillAsync(bool async)
1638private async ValueTask FillAsync(bool async)
1657private ValueTask FillForHeadersAsync(bool async)
1667async ValueTask ReadUntilEndOfHeaderAsync(bool async)
1857private ValueTask CopyFromBufferAsync(Stream destination, bool async, int count, CancellationToken cancellationToken)
2072public async ValueTask DrainResponseAsync(HttpResponseMessage response, CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\SocksHelper.cs (5)
32public static async ValueTask EstablishSocksTunnelAsync(Stream stream, string host, int port, Uri proxyUri, ICredentials? proxyCredentials, bool async, CancellationToken cancellationToken)
65private static async ValueTask EstablishSocks5TunnelAsync(Stream stream, string host, int port, NetworkCredential? credentials, bool async)
213private static async ValueTask EstablishSocks4TunnelAsync(Stream stream, bool isVersion4a, string host, int port, NetworkCredential? credentials, bool async, CancellationToken cancellationToken)
341private static ValueTask WriteAsync(Stream stream, Memory<byte> buffer, bool async)
354private static async ValueTask ReadToFillAsync(Stream stream, Memory<byte> buffer, bool async)
System.Net.Mail (12)
System.Net.Quic (30)
System\Net\Quic\QuicConnection.cs (8)
374private async ValueTask FinishConnectAsync(QuicClientConnectionOptions options, CancellationToken cancellationToken = default)
376if (_connectedTcs.TryInitialize(out ValueTask valueTask, this, cancellationToken))
451internal ValueTask FinishHandshakeAsync(QuicServerConnectionOptions options, string targetHost, CancellationToken cancellationToken = default)
453if (_connectedTcs.TryInitialize(out ValueTask valueTask, this, cancellationToken))
604public ValueTask CloseAsync(long errorCode, CancellationToken cancellationToken = default)
609if (_shutdownTcs.TryGetValueTask(out ValueTask valueTask, this, cancellationToken))
825public async ValueTask DisposeAsync()
838if (_shutdownTcs.TryGetValueTask(out ValueTask valueTask, this))
System\Net\Quic\QuicStream.cs (12)
251internal ValueTask StartAsync(Action<QuicStreamType> decrementStreamCapacity, CancellationToken cancellationToken = default)
256_startedTcs.TryInitialize(out ValueTask valueTask, this, cancellationToken);
300if (!_receiveTcs.TryGetValueTask(out ValueTask valueTask, this, cancellationToken))
352public override ValueTask WriteAsync(ReadOnlyMemory<byte> buffer, CancellationToken cancellationToken = default)
360public ValueTask WriteAsync(ReadOnlyMemory<byte> buffer, bool completeWrites, CancellationToken cancellationToken = default)
364return ValueTask.FromException(ExceptionDispatchInfo.SetCurrentStackTrace(new ObjectDisposedException(nameof(QuicStream))));
369return ValueTask.FromException(ExceptionDispatchInfo.SetCurrentStackTrace(new InvalidOperationException(SR.net_quic_writing_notallowed)));
381return ValueTask.FromCanceled(cancellationToken);
385if (!_sendTcs.TryGetValueTask(out ValueTask valueTask, this, cancellationToken))
387return ValueTask.FromException(ExceptionDispatchInfo.SetCurrentStackTrace(new InvalidOperationException(SR.Format(SR.net_io_invalidnestedcall, "write"))));
713public override async ValueTask DisposeAsync()
745if (_shutdownTcs.TryInitialize(out ValueTask valueTask, this))
System.Net.Requests (5)
System.Net.Security (25)
System.Net.Sockets (52)
System\Net\Sockets\Socket.Tasks.cs (41)
58return ValueTask.FromCanceled<Socket>(cancellationToken);
86public ValueTask ConnectAsync(EndPoint remoteEP, CancellationToken cancellationToken)
90return ValueTask.FromCanceled(cancellationToken);
100ValueTask connectTask = saea.ConnectAsync(this, saeaCancelable: cancellationToken.CanBeCanceled);
111static async ValueTask WaitForConnectWithCancellation(AwaitableSocketAsyncEventArgs saea, ValueTask connectTask, CancellationToken cancellationToken)
144public ValueTask ConnectAsync(IPAddress address, int port, CancellationToken cancellationToken) => ConnectAsync(new IPEndPoint(address, port), cancellationToken);
161public ValueTask ConnectAsync(IPAddress[] addresses, int port, CancellationToken cancellationToken)
191async ValueTask Core(IPAddress[] addresses, int port, CancellationToken cancellationToken)
238public ValueTask ConnectAsync(string host, int port, CancellationToken cancellationToken)
254public ValueTask DisconnectAsync(bool reuseSocket, CancellationToken cancellationToken = default)
258return ValueTask.FromCanceled(cancellationToken);
316return ValueTask.FromCanceled<int>(cancellationToken);
406return ValueTask.FromCanceled<SocketReceiveFromResult>(cancellationToken);
446return ValueTask.FromCanceled<int>(cancellationToken);
507return ValueTask.FromCanceled<SocketReceiveMessageFromResult>(cancellationToken);
562return ValueTask.FromCanceled<int>(cancellationToken);
576internal ValueTask SendAsyncForNetworkStream(ReadOnlyMemory<byte> buffer, SocketFlags socketFlags, CancellationToken cancellationToken)
580return ValueTask.FromCanceled(cancellationToken);
670return ValueTask.FromCanceled<int>(cancellationToken);
700return ValueTask.FromCanceled<int>(cancellationToken);
733public ValueTask SendFileAsync(string? fileName, CancellationToken cancellationToken = default)
751public ValueTask SendFileAsync(string? fileName, ReadOnlyMemory<byte> preBuffer, ReadOnlyMemory<byte> postBuffer, TransmitFileOptions flags, CancellationToken cancellationToken = default)
755return ValueTask.FromCanceled(cancellationToken);
761return ValueTask.FromException(ex);
1060ValueTask.FromException<Socket>(CreateException(error));
1080ValueTask.FromException<int>(CreateException(error));
1099ValueTask.FromException<SocketReceiveFromResult>(CreateException(error));
1117ValueTask.FromException<int>(CreateException(error));
1138ValueTask.FromException<SocketReceiveMessageFromResult>(CreateException(error));
1158ValueTask.FromException<int>(CreateException(error));
1161public ValueTask SendAsyncForNetworkStream(Socket socket, CancellationToken cancellationToken)
1175ValueTask.FromException(CreateException(error));
1178public ValueTask SendPacketsAsync(Socket socket, CancellationToken cancellationToken)
1192ValueTask.FromException(CreateException(error));
1210ValueTask.FromException<int>(CreateException(error));
1213public ValueTask ConnectAsync(Socket socket, bool saeaCancelable)
1234ValueTask.FromException(CreateException(error));
1237public ValueTask DisconnectAsync(Socket socket, CancellationToken cancellationToken)
1250ValueTask.CompletedTask :
1251ValueTask.FromException(CreateException(error));
System\Net\Sockets\SocketTaskExtensions.cs (4)
25public static ValueTask ConnectAsync(this Socket socket, EndPoint remoteEP, CancellationToken cancellationToken) =>
31public static ValueTask ConnectAsync(this Socket socket, IPAddress address, int port, CancellationToken cancellationToken) =>
37public static ValueTask ConnectAsync(this Socket socket, IPAddress[] addresses, int port, CancellationToken cancellationToken) =>
43public static ValueTask ConnectAsync(this Socket socket, string host, int port, CancellationToken cancellationToken) =>
System.Net.WebClient (5)
System.Net.WebSockets (26)
System\Net\WebSockets\ManagedWebSocket.cs (20)
314public override ValueTask SendAsync(ReadOnlyMemory<byte> buffer, WebSocketMessageType messageType, bool endOfMessage, CancellationToken cancellationToken) =>
317public override ValueTask SendAsync(ReadOnlyMemory<byte> buffer, WebSocketMessageType messageType, WebSocketMessageFlags messageFlags, CancellationToken cancellationToken)
336return ValueTask.FromException(exc);
356ValueTask t = SendFrameAsync(opcode, endOfMessage, disableCompression, buffer, cancellationToken);
395return ValueTask.FromException<ValueWebSocketReceiveResult>(exc);
484private ValueTask SendFrameAsync(MessageOpcode opcode, bool endOfMessage, bool disableCompression, ReadOnlyMemory<byte> payloadBuffer, CancellationToken cancellationToken)
503private ValueTask SendFrameLockAcquiredNonCancelableAsync(MessageOpcode opcode, bool endOfMessage, bool disableCompression, ReadOnlyMemory<byte> payloadBuffer)
511ValueTask writeTask = default;
525ValueTask flushTask = new ValueTask(_stream.FlushAsync());
546return ValueTask.FromException(
569private async ValueTask WaitForWriteTaskAsync(ValueTask writeTask, bool shouldFlush)
605private async ValueTask SendFrameFallbackAsync(MessageOpcode opcode, bool endOfMessage, bool disableCompression, ReadOnlyMemory<byte> payloadBuffer, Task lockTask, CancellationToken cancellationToken)
1068private async ValueTask HandleReceivedCloseAsync(MessageHeader header, CancellationToken cancellationToken)
1138private async ValueTask WaitForServerToCloseConnectionAsync(CancellationToken cancellationToken)
1175private async ValueTask HandleReceivedPingPongAsync(MessageHeader header, CancellationToken cancellationToken)
1278private async ValueTask CloseWithReceiveErrorAndThrowAsync(
1522private async ValueTask SendCloseFrameAsync(WebSocketCloseStatus closeStatus, string? closeStatusDescription, CancellationToken cancellationToken)
1585private async ValueTask EnsureBufferContainsAsync(int minimumRequiredBytes, CancellationToken cancellationToken)
1860private void LogExceptions(ValueTask t)
System.Net.WebSockets.Client (2)
System.Private.CoreLib (165)
System.Private.Xml (7)
System.Runtime (1)
System.Security.Cryptography (33)
System.ServiceModel.NetFramingBase (44)
System.ServiceModel.NetNamedPipe (7)
System.ServiceModel.UnixDomainSocket (5)
System.Text.Json (3)
System.Threading.Channels (15)
System.Threading.RateLimiting (11)
System.Threading.Tasks.Extensions (1)
System.Threading.Tasks.Parallel (18)
System\Threading\Tasks\Parallel.ForEachAsync.cs (18)
20public static Task ForAsync<T>(T fromInclusive, T toExclusive, Func<T, CancellationToken, ValueTask> body)
38public static Task ForAsync<T>(T fromInclusive, T toExclusive, CancellationToken cancellationToken, Func<T, CancellationToken, ValueTask> body)
56public static Task ForAsync<T>(T fromInclusive, T toExclusive, ParallelOptions parallelOptions, Func<T, CancellationToken, ValueTask> body)
77private static Task ForAsync<T>(T fromInclusive, T toExclusive, int dop, TaskScheduler scheduler, CancellationToken cancellationToken, Func<T, CancellationToken, ValueTask> body)
198public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask> body)
214public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, CancellationToken cancellationToken, Func<TSource, CancellationToken, ValueTask> body)
229public static Task ForEachAsync<TSource>(IEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)
247private static Task ForEachAsync<TSource>(IEnumerable<TSource> source, int dop, TaskScheduler scheduler, CancellationToken cancellationToken, Func<TSource, CancellationToken, ValueTask> body)
353public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask> body)
369public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, CancellationToken cancellationToken, Func<TSource, CancellationToken, ValueTask> body)
384public static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, ParallelOptions parallelOptions, Func<TSource, CancellationToken, ValueTask> body)
402private static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, int dop, TaskScheduler scheduler, CancellationToken cancellationToken, Func<TSource, CancellationToken, ValueTask> body)
535public readonly Func<TSource, CancellationToken, ValueTask> LoopBody;
540protected ForEachAsyncState(Func<object, Task> taskBody, bool needsLock, int dop, TaskScheduler scheduler, CancellationToken cancellationToken, Func<TSource, CancellationToken, ValueTask> body)
693Func<TSource, CancellationToken, ValueTask> body) :
715Func<TSource, CancellationToken, ValueTask> body) :
721public ValueTask DisposeAsync()
738Func<T, CancellationToken, ValueTask> body) :
System.Windows.Forms (6)
TestProject.IntegrationServiceA (1)
xunit.assert (1)