IQueueItem

1 implementation of IQueueItem

Microsoft.CodeAnalysis.LanguageServer.Protocol (1)

src\LanguageServer\Microsoft.CommonLanguageServerProtocol.Framework\QueueItem.cs (1)

24internal class QueueItem<TRequestContext> : IQueueItem<TRequestContext>

13 references to IQueueItem

Microsoft.CodeAnalysis.LanguageServer.Protocol (13)

Handler\RequestContextFactory.cs (1)

22public override Task<RequestContext> CreateRequestContextAsync<TRequestParam>(IQueueItem<RequestContext> queueItem, IMethodHandler methodHandler, TRequestParam requestParam, CancellationToken cancellationToken)

src\LanguageServer\Microsoft.CommonLanguageServerProtocol.Framework\AbstractRequestContextFactory.cs (5)

15/// A factory for creating <typeparamref name="TRequestContext"/> objects from <see cref="IQueueItem{RequestContextType}"/>'s. 18/// RequestContext's are useful for passing document context, since by default <see cref="CreateRequestContextAsync{TRequestParam}(IQueueItem{TRequestContext}, IMethodHandler, TRequestParam, CancellationToken)"/> 27/// Create a <typeparamref name="TRequestContext"/> object from the given <see cref="IQueueItem{RequestContextType}"/>. 30/// <param name="queueItem">The <see cref="IQueueItem{RequestContextType}"/> from which to create the request context.</param> 36public abstract Task<TRequestContext> CreateRequestContextAsync<TRequestParam>(IQueueItem<TRequestContext> queueItem, IMethodHandler methodHandler, TRequestParam requestParam, CancellationToken cancellationToken);

src\LanguageServer\Microsoft.CommonLanguageServerProtocol.Framework\QueueItem.cs (1)

69public static (IQueueItem<TRequestContext>, Task<object?>) Create(

src\LanguageServer\Microsoft.CommonLanguageServerProtocol.Framework\RequestExecutionQueue.cs (6)

70protected readonly AsyncQueue<(IQueueItem<TRequestContext> queueItem, Guid ActivityId, CancellationToken cancellationToken)> _queue = new(); 203(IQueueItem<TRequestContext> work, Guid activityId, CancellationToken cancellationToken) queueItem; 301/// Reflection invokes <see cref="ProcessQueueCoreAsync{TRequest, TResponse}(IQueueItem{TRequestContext}, IMethodHandler, RequestHandlerMetadata, ConcurrentDictionary{Task, CancellationTokenSource}, CancellationTokenSource?, CancellationToken)"/> 305IQueueItem<TRequestContext> work, 328IQueueItem<TRequestContext> work, 411private (RequestHandlerMetadata Metadata, IMethodHandler Handler, MethodInfo MethodInfo) GetHandlerForRequest(IQueueItem<TRequestContext> work, string language)