9 instantiations of AsyncQueue
Microsoft.CodeAnalysis (8)
DiagnosticAnalyzer\AnalyzerDriver.cs (1)
858.WithEventQueue(new AsyncQueue<CompilationEvent>());
DiagnosticAnalyzer\CompilationWithAnalyzers.cs (5)
44private static readonly AsyncQueue<CompilationEvent> s_EmptyEventQueue = new AsyncQueue<CompilationEvent>(); 101.WithEventQueue(new AsyncQueue<CompilationEvent>()); 300var compilation = _compilation.WithEventQueue(new AsyncQueue<CompilationEvent>()); 721: _compilation.WithSemanticModelProvider(CachingSemanticModelProvider.Instance).WithEventQueue(new AsyncQueue<CompilationEvent>()); 1143var eventQueue = new AsyncQueue<CompilationEvent>();
DiagnosticAnalyzer\DiagnosticQueue.cs (2)
44_queue = new AsyncQueue<Diagnostic>(); 49_queue = new AsyncQueue<Diagnostic>();
VBCSCompiler (1)
src\roslyn\src\Compilers\Server\VBCSCompiler\NamedPipeClientConnectionHost.cs (1)
60_queue = new AsyncQueue<ListenResult>();
21 references to AsyncQueue
Microsoft.CodeAnalysis (16)
Compilation\Compilation.cs (3)
83AsyncQueue<CompilationEvent>? eventQueue) 320internal abstract Compilation WithEventQueue(AsyncQueue<CompilationEvent>? eventQueue); 670internal AsyncQueue<CompilationEvent>? EventQueue { get; }
DiagnosticAnalyzer\AnalyzerDriver.cs (6)
26/// It uses a <see cref="AsyncQueue{TElement}"/> of <see cref="CompilationEvent"/>s to drive its analysis. 339private AsyncQueue<CompilationEvent>? _lazyCompilationEventQueue; 344public AsyncQueue<CompilationEvent> CompilationEventQueue 645internal async Task AttachQueueAndProcessAllEventsAsync(AsyncQueue<CompilationEvent> eventQueue, AnalysisScope analysisScope, CancellationToken cancellationToken) 674internal void AttachQueueAndStartProcessingEvents(AsyncQueue<CompilationEvent> eventQueue, AnalysisScope analysisScope, bool usingPrePopulatedEventQueue, CancellationToken cancellationToken) 2428/// It uses a <see cref="AsyncQueue{TElement}"/> of <see cref="CompilationEvent"/>s to drive its analysis.
DiagnosticAnalyzer\AsyncQueue.cs (1)
163/// Same operation as <see cref="AsyncQueue{TElement}.Complete"/> except it will not
DiagnosticAnalyzer\CompilationWithAnalyzers.cs (5)
44private static readonly AsyncQueue<CompilationEvent> s_EmptyEventQueue = new AsyncQueue<CompilationEvent>(); 825var eventQueue = CreateEventsQueue(compilationEvents); 1050var eventQueue = compilation.EventQueue!; 1136private static AsyncQueue<CompilationEvent> CreateEventsQueue(ImmutableArray<CompilationEvent> compilationEvents) 1143var eventQueue = new AsyncQueue<CompilationEvent>();
DiagnosticAnalyzer\DiagnosticQueue.cs (1)
40private readonly AsyncQueue<Diagnostic> _queue;
Microsoft.CodeAnalysis.CSharp (3)
Compilation\CSharpCompilation.cs (3)
546AsyncQueue<CompilationEvent>? eventQueue = null) 564AsyncQueue<CompilationEvent>? eventQueue = null) 826internal override Compilation WithEventQueue(AsyncQueue<CompilationEvent>? eventQueue)
VBCSCompiler (2)
src\roslyn\src\Compilers\Server\VBCSCompiler\NamedPipeClientConnectionHost.cs (2)
35private AsyncQueue<ListenResult>? _queue; 170AsyncQueue<ListenResult> queue,